|
@@ 357-363 (lines=7) @@
|
| 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) |
| 360 |
|
. ($frame->multiple ? "\x01" : "\x00"); |
| 361 |
|
|
| 362 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 363 |
|
} |
| 364 |
|
if ($frame instanceof Basic\BasicRejectFrame) { |
| 365 |
|
$payload = "\x00\x3c\x00\x5a" |
| 366 |
|
. \pack('J', $frame->deliveryTag) |
|
@@ 364-370 (lines=7) @@
|
| 361 |
|
|
| 362 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 363 |
|
} |
| 364 |
|
if ($frame instanceof Basic\BasicRejectFrame) { |
| 365 |
|
$payload = "\x00\x3c\x00\x5a" |
| 366 |
|
. \pack('J', $frame->deliveryTag) |
| 367 |
|
. ($frame->requeue ? "\x01" : "\x00"); |
| 368 |
|
|
| 369 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 370 |
|
} |
| 371 |
|
if ($frame instanceof Basic\BasicRecoverFrame) { |
| 372 |
|
$payload = "\x00\x3c\x00\x6e" |
| 373 |
|
. ($frame->requeue ? "\x01" : "\x00"); |
|
@@ 377-386 (lines=10) @@
|
| 374 |
|
|
| 375 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 376 |
|
} |
| 377 |
|
if ($frame instanceof Basic\BasicNackFrame) { |
| 378 |
|
$payload = "\x00\x3c\x00\x78" |
| 379 |
|
. \pack('J', $frame->deliveryTag) |
| 380 |
|
. \chr( |
| 381 |
|
$frame->multiple |
| 382 |
|
| $frame->requeue << 1 |
| 383 |
|
); |
| 384 |
|
|
| 385 |
|
return "\x01" . \pack('nN', $frame->frameChannelId, \strlen($payload)) . $payload . "\xce"; |
| 386 |
|
} |
| 387 |
|
if ($frame instanceof Tx\TxSelectFrame) { |
| 388 |
|
return "\x01" . \pack('n', $frame->frameChannelId) . "\x00\x00\x00\x04\x00\x5a\x00\x0a\xce"; |
| 389 |
|
} |