|
@@ 200-206 (lines=7) @@
|
| 197 |
|
|
| 198 |
|
return $this->packX01Payload($frame, $payload); |
| 199 |
|
|
| 200 |
|
case $frame instanceof Queue\QueuePurgeFrame: |
| 201 |
|
$payload = "\x00\x32\x00\x1e" |
| 202 |
|
. \pack('n', $frame->reserved1) |
| 203 |
|
. $this->serializeShortString($frame->queue) |
| 204 |
|
. ($frame->nowait ? "\x01" : "\x00"); |
| 205 |
|
|
| 206 |
|
return $this->packX01Payload($frame, $payload); |
| 207 |
|
|
| 208 |
|
case $frame instanceof Queue\QueueDeleteFrame: |
| 209 |
|
$payload = "\x00\x32\x00\x28" |
|
@@ 351-357 (lines=7) @@
|
| 348 |
|
|
| 349 |
|
return $this->packX01Payload($frame, $payload); |
| 350 |
|
|
| 351 |
|
case $frame instanceof Basic\BasicGetFrame: |
| 352 |
|
$payload = "\x00\x3c\x00\x46" |
| 353 |
|
. \pack('n', $frame->reserved1) |
| 354 |
|
. $this->serializeShortString($frame->queue) |
| 355 |
|
. ($frame->noAck ? "\x01" : "\x00"); |
| 356 |
|
|
| 357 |
|
return $this->packX01Payload($frame, $payload); |
| 358 |
|
|
| 359 |
|
case $frame instanceof Basic\BasicAckFrame: |
| 360 |
|
$payload = "\x00\x3c\x00\x50" |