kakserpom /
phpdaemon
| @@ 54-57 (lines=4) @@ | ||
| 51 | } |
|
| 52 | ||
| 53 | // consume "delivery-mode" (octet) |
|
| 54 | if ($flags & 4096) { |
|
| 55 | list(, $frame->deliveryMode) = \unpack('c', $this->buffer); |
|
| 56 | $this->buffer = \substr($this->buffer, 1); |
|
| 57 | } |
|
| 58 | ||
| 59 | // consume "priority" (octet) |
|
| 60 | if ($flags & 2048) { |
|
| @@ 60-63 (lines=4) @@ | ||
| 57 | } |
|
| 58 | ||
| 59 | // consume "priority" (octet) |
|
| 60 | if ($flags & 2048) { |
|
| 61 | list(, $frame->priority) = \unpack('c', $this->buffer); |
|
| 62 | $this->buffer = \substr($this->buffer, 1); |
|
| 63 | } |
|
| 64 | ||
| 65 | // consume "correlation-id" (shortstr) |
|
| 66 | if ($flags & 1024) { |
|
| @@ 94-97 (lines=4) @@ | ||
| 91 | } |
|
| 92 | ||
| 93 | // consume "timestamp" (timestamp) |
|
| 94 | if ($flags & 64) { |
|
| 95 | list(, $frame->timestamp) = \unpack('J', $this->buffer); |
|
| 96 | $this->buffer = \substr($this->buffer, 8); |
|
| 97 | } |
|
| 98 | ||
| 99 | // consume "type" (shortstr) |
|
| 100 | if ($flags & 32) { |
|
