|
@@ 125-139 (lines=15) @@
|
| 122 |
|
|
| 123 |
|
return $this->packX01Payload($frame, $payload); |
| 124 |
|
|
| 125 |
|
case $frame instanceof Exchange\ExchangeDeclareFrame: |
| 126 |
|
$payload = "\x00\x28\x00\x0a" |
| 127 |
|
. \pack('n', $frame->reserved1) |
| 128 |
|
. $this->serializeShortString($frame->exchange) |
| 129 |
|
. $this->serializeShortString($frame->type) |
| 130 |
|
. \chr( |
| 131 |
|
$frame->passive |
| 132 |
|
| $frame->durable << 1 |
| 133 |
|
| $frame->autoDelete << 2 |
| 134 |
|
| $frame->internal << 3 |
| 135 |
|
| $frame->nowait << 4 |
| 136 |
|
) |
| 137 |
|
. $this->tableSerializer->serialize($frame->arguments); |
| 138 |
|
|
| 139 |
|
return $this->packX01Payload($frame, $payload); |
| 140 |
|
|
| 141 |
|
case $frame instanceof Exchange\ExchangeDeleteFrame: |
| 142 |
|
$payload = "\x00\x28\x00\x14" |
|
@@ 174-187 (lines=14) @@
|
| 171 |
|
|
| 172 |
|
return $this->packX01Payload($frame, $payload); |
| 173 |
|
|
| 174 |
|
case $frame instanceof Queue\QueueDeclareFrame: |
| 175 |
|
$payload = "\x00\x32\x00\x0a" |
| 176 |
|
. \pack('n', $frame->reserved1) |
| 177 |
|
. $this->serializeShortString($frame->queue) |
| 178 |
|
. \chr( |
| 179 |
|
$frame->passive |
| 180 |
|
| $frame->durable << 1 |
| 181 |
|
| $frame->exclusive << 2 |
| 182 |
|
| $frame->autoDelete << 3 |
| 183 |
|
| $frame->nowait << 4 |
| 184 |
|
) |
| 185 |
|
. $this->tableSerializer->serialize($frame->arguments); |
| 186 |
|
|
| 187 |
|
return $this->packX01Payload($frame, $payload); |
| 188 |
|
|
| 189 |
|
case $frame instanceof Queue\QueueBindFrame: |
| 190 |
|
$payload = "\x00\x32\x00\x14" |
|
@@ 317-330 (lines=14) @@
|
| 314 |
|
|
| 315 |
|
return $this->packX01Payload($frame, $payload); |
| 316 |
|
|
| 317 |
|
case $frame instanceof Basic\BasicConsumeFrame: |
| 318 |
|
$payload = "\x00\x3c\x00\x14" |
| 319 |
|
. \pack('n', $frame->reserved1) |
| 320 |
|
. $this->serializeShortString($frame->queue) |
| 321 |
|
. $this->serializeShortString($frame->consumerTag) |
| 322 |
|
. \chr( |
| 323 |
|
$frame->noLocal |
| 324 |
|
| $frame->noAck << 1 |
| 325 |
|
| $frame->exclusive << 2 |
| 326 |
|
| $frame->nowait << 3 |
| 327 |
|
) |
| 328 |
|
. $this->tableSerializer->serialize($frame->arguments); |
| 329 |
|
|
| 330 |
|
return $this->packX01Payload($frame, $payload); |
| 331 |
|
|
| 332 |
|
case $frame instanceof Basic\BasicCancelFrame: |
| 333 |
|
$payload = "\x00\x3c\x00\x1e" |
kakserpom /
phpdaemon
