videlalvaro /
php-amqplib
| @@ 650-656 (lines=7) @@ | ||
| 647 | /** |
|
| 648 | * @return array |
|
| 649 | */ |
|
| 650 | public function basicAck($delivery_tag = 0, $multiple = false) |
|
| 651 | { |
|
| 652 | $args = new AMQPWriter(); |
|
| 653 | $args->write_longlong($delivery_tag); |
|
| 654 | $args->write_bits(array($multiple)); |
|
| 655 | return array(60, 80, $args); |
|
| 656 | } |
|
| 657 | ||
| 658 | ||
| 659 | ||
| @@ 663-669 (lines=7) @@ | ||
| 660 | /** |
|
| 661 | * @return array |
|
| 662 | */ |
|
| 663 | public function basicReject($delivery_tag, $requeue = true) |
|
| 664 | { |
|
| 665 | $args = new AMQPWriter(); |
|
| 666 | $args->write_longlong($delivery_tag); |
|
| 667 | $args->write_bits(array($requeue)); |
|
| 668 | return array(60, 90, $args); |
|
| 669 | } |
|
| 670 | ||
| 671 | ||
| 672 | ||
| @@ 877-883 (lines=7) @@ | ||
| 874 | /** |
|
| 875 | * @return array |
|
| 876 | */ |
|
| 877 | public function fileAck($delivery_tag = 0, $multiple = false) |
|
| 878 | { |
|
| 879 | $args = new AMQPWriter(); |
|
| 880 | $args->write_longlong($delivery_tag); |
|
| 881 | $args->write_bits(array($multiple)); |
|
| 882 | return array(70, 90, $args); |
|
| 883 | } |
|
| 884 | ||
| 885 | ||
| 886 | ||
| @@ 890-896 (lines=7) @@ | ||
| 887 | /** |
|
| 888 | * @return array |
|
| 889 | */ |
|
| 890 | public function fileReject($delivery_tag, $requeue = true) |
|
| 891 | { |
|
| 892 | $args = new AMQPWriter(); |
|
| 893 | $args->write_longlong($delivery_tag); |
|
| 894 | $args->write_bits(array($requeue)); |
|
| 895 | return array(70, 100, $args); |
|
| 896 | } |
|
| 897 | ||
| 898 | ||
| 899 | ||
| @@ 707-713 (lines=7) @@ | ||
| 704 | /** |
|
| 705 | * @return array |
|
| 706 | */ |
|
| 707 | public function basicAck($delivery_tag = 0, $multiple = false) |
|
| 708 | { |
|
| 709 | $args = new AMQPWriter(); |
|
| 710 | $args->write_longlong($delivery_tag); |
|
| 711 | $args->write_bits(array($multiple)); |
|
| 712 | return array(60, 80, $args); |
|
| 713 | } |
|
| 714 | ||
| 715 | ||
| 716 | ||
| @@ 720-726 (lines=7) @@ | ||
| 717 | /** |
|
| 718 | * @return array |
|
| 719 | */ |
|
| 720 | public function basicReject($delivery_tag, $requeue = true) |
|
| 721 | { |
|
| 722 | $args = new AMQPWriter(); |
|
| 723 | $args->write_longlong($delivery_tag); |
|
| 724 | $args->write_bits(array($requeue)); |
|
| 725 | return array(60, 90, $args); |
|
| 726 | } |
|
| 727 | ||
| 728 | ||
| 729 | ||
| @@ 769-775 (lines=7) @@ | ||
| 766 | /** |
|
| 767 | * @return array |
|
| 768 | */ |
|
| 769 | public function basicNack($delivery_tag = 0, $multiple = false, $requeue = true) |
|
| 770 | { |
|
| 771 | $args = new AMQPWriter(); |
|
| 772 | $args->write_longlong($delivery_tag); |
|
| 773 | $args->write_bits(array($multiple, $requeue)); |
|
| 774 | return array(60, 120, $args); |
|
| 775 | } |
|
| 776 | ||
| 777 | ||
| 778 | ||
