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