|
@@ 141-150 (lines=10) @@
|
| 138 |
|
|
| 139 |
|
return $this->packX01Payload($frame, $payload); |
| 140 |
|
|
| 141 |
|
case $frame instanceof Exchange\ExchangeDeleteFrame: |
| 142 |
|
$payload = "\x00\x28\x00\x14" |
| 143 |
|
. \pack('n', $frame->reserved1) |
| 144 |
|
. $this->serializeShortString($frame->exchange) |
| 145 |
|
. \chr( |
| 146 |
|
$frame->ifUnused |
| 147 |
|
| $frame->nowait << 1 |
| 148 |
|
); |
| 149 |
|
|
| 150 |
|
return $this->packX01Payload($frame, $payload); |
| 151 |
|
|
| 152 |
|
case $frame instanceof Exchange\ExchangeBindFrame: |
| 153 |
|
$payload = "\x00\x28\x00\x1e" |
|
@@ 208-218 (lines=11) @@
|
| 205 |
|
|
| 206 |
|
return $this->packX01Payload($frame, $payload); |
| 207 |
|
|
| 208 |
|
case $frame instanceof Queue\QueueDeleteFrame: |
| 209 |
|
$payload = "\x00\x32\x00\x28" |
| 210 |
|
. \pack('n', $frame->reserved1) |
| 211 |
|
. $this->serializeShortString($frame->queue) |
| 212 |
|
. \chr( |
| 213 |
|
$frame->ifUnused |
| 214 |
|
| $frame->ifEmpty << 1 |
| 215 |
|
| $frame->nowait << 2 |
| 216 |
|
); |
| 217 |
|
|
| 218 |
|
return $this->packX01Payload($frame, $payload); |
| 219 |
|
|
| 220 |
|
case $frame instanceof Queue\QueueUnbindFrame: |
| 221 |
|
$payload = "\x00\x32\x00\x32" |
|
@@ 339-349 (lines=11) @@
|
| 336 |
|
|
| 337 |
|
return $this->packX01Payload($frame, $payload); |
| 338 |
|
|
| 339 |
|
case $frame instanceof Basic\BasicPublishFrame: |
| 340 |
|
$payload = "\x00\x3c\x00\x28" |
| 341 |
|
. \pack('n', $frame->reserved1) |
| 342 |
|
. $this->serializeShortString($frame->exchange) |
| 343 |
|
. $this->serializeShortString($frame->routingKey) |
| 344 |
|
. \chr( |
| 345 |
|
$frame->mandatory |
| 346 |
|
| $frame->immediate << 1 |
| 347 |
|
); |
| 348 |
|
|
| 349 |
|
return $this->packX01Payload($frame, $payload); |
| 350 |
|
|
| 351 |
|
case $frame instanceof Basic\BasicGetFrame: |
| 352 |
|
$payload = "\x00\x3c\x00\x46" |
kakserpom /
phpdaemon
