|
@@ 139-149 (lines=11) @@
|
| 136 |
|
|
| 137 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 138 |
|
} |
| 139 |
|
if ($frame instanceof Exchange\ExchangeDeleteFrame) { |
| 140 |
|
$payload = "\x00\x28\x00\x14" |
| 141 |
|
. \pack('n', $frame->reserved1) |
| 142 |
|
. $this->serializeShortString($frame->exchange) |
| 143 |
|
. \chr( |
| 144 |
|
$frame->ifUnused |
| 145 |
|
| $frame->nowait << 1 |
| 146 |
|
); |
| 147 |
|
|
| 148 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 149 |
|
} |
| 150 |
|
if ($frame instanceof Exchange\ExchangeBindFrame) { |
| 151 |
|
$payload = "\x00\x28\x00\x1e" |
| 152 |
|
. \pack('n', $frame->reserved1) |
|
@@ 198-205 (lines=8) @@
|
| 195 |
|
|
| 196 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 197 |
|
} |
| 198 |
|
if ($frame instanceof Queue\QueuePurgeFrame) { |
| 199 |
|
$payload = "\x00\x32\x00\x1e" |
| 200 |
|
. \pack('n', $frame->reserved1) |
| 201 |
|
. $this->serializeShortString($frame->queue) |
| 202 |
|
. ($frame->nowait ? "\x01" : "\x00"); |
| 203 |
|
|
| 204 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 205 |
|
} |
| 206 |
|
if ($frame instanceof Queue\QueueDeleteFrame) { |
| 207 |
|
$payload = "\x00\x32\x00\x28" |
| 208 |
|
. \pack('n', $frame->reserved1) |
|
@@ 206-217 (lines=12) @@
|
| 203 |
|
|
| 204 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 205 |
|
} |
| 206 |
|
if ($frame instanceof Queue\QueueDeleteFrame) { |
| 207 |
|
$payload = "\x00\x32\x00\x28" |
| 208 |
|
. \pack('n', $frame->reserved1) |
| 209 |
|
. $this->serializeShortString($frame->queue) |
| 210 |
|
. \chr( |
| 211 |
|
$frame->ifUnused |
| 212 |
|
| $frame->ifEmpty << 1 |
| 213 |
|
| $frame->nowait << 2 |
| 214 |
|
); |
| 215 |
|
|
| 216 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 217 |
|
} |
| 218 |
|
if ($frame instanceof Queue\QueueUnbindFrame) { |
| 219 |
|
$payload = "\x00\x32\x00\x32" |
| 220 |
|
. \pack('n', $frame->reserved1) |
|
@@ 337-348 (lines=12) @@
|
| 334 |
|
|
| 335 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 336 |
|
} |
| 337 |
|
if ($frame instanceof Basic\BasicPublishFrame) { |
| 338 |
|
$payload = "\x00\x3c\x00\x28" |
| 339 |
|
. \pack('n', $frame->reserved1) |
| 340 |
|
. $this->serializeShortString($frame->exchange) |
| 341 |
|
. $this->serializeShortString($frame->routingKey) |
| 342 |
|
. \chr( |
| 343 |
|
$frame->mandatory |
| 344 |
|
| $frame->immediate << 1 |
| 345 |
|
); |
| 346 |
|
|
| 347 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 348 |
|
} |
| 349 |
|
if ($frame instanceof Basic\BasicGetFrame) { |
| 350 |
|
$payload = "\x00\x3c\x00\x46" |
| 351 |
|
. \pack('n', $frame->reserved1) |
|
@@ 349-356 (lines=8) @@
|
| 346 |
|
|
| 347 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 348 |
|
} |
| 349 |
|
if ($frame instanceof Basic\BasicGetFrame) { |
| 350 |
|
$payload = "\x00\x3c\x00\x46" |
| 351 |
|
. \pack('n', $frame->reserved1) |
| 352 |
|
. $this->serializeShortString($frame->queue) |
| 353 |
|
. ($frame->noAck ? "\x01" : "\x00"); |
| 354 |
|
|
| 355 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 356 |
|
} |
| 357 |
|
if ($frame instanceof Basic\BasicAckFrame) { |
| 358 |
|
$payload = "\x00\x3c\x00\x50" |
| 359 |
|
. \pack('J', $frame->deliveryTag) |
kakserpom /
phpdaemon
