@@ 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 | } |