@@ 590-599 (lines=10) @@ | ||
587 | /** |
|
588 | * @return array |
|
589 | */ |
|
590 | public function basicDeliver($consumer_tag, $delivery_tag, $redelivered = false, $exchange, $routing_key) |
|
591 | { |
|
592 | $args = new AMQPWriter(); |
|
593 | $args->write_shortstr($consumer_tag); |
|
594 | $args->write_longlong($delivery_tag); |
|
595 | $args->write_bits(array($redelivered)); |
|
596 | $args->write_shortstr($exchange); |
|
597 | $args->write_shortstr($routing_key); |
|
598 | return array(60, 60, $args); |
|
599 | } |
|
600 | ||
601 | ||
602 | ||
@@ 860-870 (lines=11) @@ | ||
857 | /** |
|
858 | * @return array |
|
859 | */ |
|
860 | public function fileDeliver($consumer_tag, $delivery_tag, $redelivered = false, $exchange, $routing_key, $identifier) |
|
861 | { |
|
862 | $args = new AMQPWriter(); |
|
863 | $args->write_shortstr($consumer_tag); |
|
864 | $args->write_longlong($delivery_tag); |
|
865 | $args->write_bits(array($redelivered)); |
|
866 | $args->write_shortstr($exchange); |
|
867 | $args->write_shortstr($routing_key); |
|
868 | $args->write_shortstr($identifier); |
|
869 | return array(70, 80, $args); |
|
870 | } |
|
871 | ||
872 | ||
873 |
@@ 647-656 (lines=10) @@ | ||
644 | /** |
|
645 | * @return array |
|
646 | */ |
|
647 | public function basicDeliver($consumer_tag, $delivery_tag, $redelivered = false, $exchange, $routing_key) |
|
648 | { |
|
649 | $args = new AMQPWriter(); |
|
650 | $args->write_shortstr($consumer_tag); |
|
651 | $args->write_longlong($delivery_tag); |
|
652 | $args->write_bits(array($redelivered)); |
|
653 | $args->write_shortstr($exchange); |
|
654 | $args->write_shortstr($routing_key); |
|
655 | return array(60, 60, $args); |
|
656 | } |
|
657 | ||
658 | ||
659 |