videlalvaro /
php-amqplib
| @@ 142-150 (lines=9) @@ | ||
| 139 | /** |
|
| 140 | * @return array |
|
| 141 | */ |
|
| 142 | public function connectionClose($reply_code, $reply_text = '', $class_id, $method_id) |
|
| 143 | { |
|
| 144 | $args = new AMQPWriter(); |
|
| 145 | $args->write_short($reply_code); |
|
| 146 | $args->write_shortstr($reply_text); |
|
| 147 | $args->write_short($class_id); |
|
| 148 | $args->write_short($method_id); |
|
| 149 | return array(10, 60, $args); |
|
| 150 | } |
|
| 151 | ||
| 152 | ||
| 153 | ||
| @@ 232-240 (lines=9) @@ | ||
| 229 | /** |
|
| 230 | * @return array |
|
| 231 | */ |
|
| 232 | public function channelClose($reply_code, $reply_text = '', $class_id, $method_id) |
|
| 233 | { |
|
| 234 | $args = new AMQPWriter(); |
|
| 235 | $args->write_short($reply_code); |
|
| 236 | $args->write_shortstr($reply_text); |
|
| 237 | $args->write_short($class_id); |
|
| 238 | $args->write_short($method_id); |
|
| 239 | return array(20, 40, $args); |
|
| 240 | } |
|
| 241 | ||
| 242 | ||
| 243 | ||
| @@ 575-583 (lines=9) @@ | ||
| 572 | /** |
|
| 573 | * @return array |
|
| 574 | */ |
|
| 575 | public function basicReturn($reply_code, $reply_text = '', $exchange, $routing_key) |
|
| 576 | { |
|
| 577 | $args = new AMQPWriter(); |
|
| 578 | $args->write_short($reply_code); |
|
| 579 | $args->write_shortstr($reply_text); |
|
| 580 | $args->write_shortstr($exchange); |
|
| 581 | $args->write_shortstr($routing_key); |
|
| 582 | return array(60, 50, $args); |
|
| 583 | } |
|
| 584 | ||
| 585 | ||
| 586 | ||
| @@ 845-853 (lines=9) @@ | ||
| 842 | /** |
|
| 843 | * @return array |
|
| 844 | */ |
|
| 845 | public function fileReturn($reply_code = 200, $reply_text = '', $exchange, $routing_key) |
|
| 846 | { |
|
| 847 | $args = new AMQPWriter(); |
|
| 848 | $args->write_short($reply_code); |
|
| 849 | $args->write_shortstr($reply_text); |
|
| 850 | $args->write_shortstr($exchange); |
|
| 851 | $args->write_shortstr($routing_key); |
|
| 852 | return array(70, 70, $args); |
|
| 853 | } |
|
| 854 | ||
| 855 | ||
| 856 | ||
| @@ 999-1007 (lines=9) @@ | ||
| 996 | /** |
|
| 997 | * @return array |
|
| 998 | */ |
|
| 999 | public function streamReturn($reply_code = 200, $reply_text = '', $exchange, $routing_key) |
|
| 1000 | { |
|
| 1001 | $args = new AMQPWriter(); |
|
| 1002 | $args->write_short($reply_code); |
|
| 1003 | $args->write_shortstr($reply_text); |
|
| 1004 | $args->write_shortstr($exchange); |
|
| 1005 | $args->write_shortstr($routing_key); |
|
| 1006 | return array(80, 50, $args); |
|
| 1007 | } |
|
| 1008 | ||
| 1009 | ||
| 1010 | ||
| @@ 129-137 (lines=9) @@ | ||
| 126 | /** |
|
| 127 | * @return array |
|
| 128 | */ |
|
| 129 | public function connectionClose($reply_code, $reply_text = '', $class_id, $method_id) |
|
| 130 | { |
|
| 131 | $args = new AMQPWriter(); |
|
| 132 | $args->write_short($reply_code); |
|
| 133 | $args->write_shortstr($reply_text); |
|
| 134 | $args->write_short($class_id); |
|
| 135 | $args->write_short($method_id); |
|
| 136 | return array(10, 50, $args); |
|
| 137 | } |
|
| 138 | ||
| 139 | ||
| 140 | ||
| @@ 230-238 (lines=9) @@ | ||
| 227 | /** |
|
| 228 | * @return array |
|
| 229 | */ |
|
| 230 | public function channelClose($reply_code, $reply_text = '', $class_id, $method_id) |
|
| 231 | { |
|
| 232 | $args = new AMQPWriter(); |
|
| 233 | $args->write_short($reply_code); |
|
| 234 | $args->write_shortstr($reply_text); |
|
| 235 | $args->write_short($class_id); |
|
| 236 | $args->write_short($method_id); |
|
| 237 | return array(20, 40, $args); |
|
| 238 | } |
|
| 239 | ||
| 240 | ||
| 241 | ||
| @@ 632-640 (lines=9) @@ | ||
| 629 | /** |
|
| 630 | * @return array |
|
| 631 | */ |
|
| 632 | public function basicReturn($reply_code, $reply_text = '', $exchange, $routing_key) |
|
| 633 | { |
|
| 634 | $args = new AMQPWriter(); |
|
| 635 | $args->write_short($reply_code); |
|
| 636 | $args->write_shortstr($reply_text); |
|
| 637 | $args->write_shortstr($exchange); |
|
| 638 | $args->write_shortstr($routing_key); |
|
| 639 | return array(60, 50, $args); |
|
| 640 | } |
|
| 641 | ||
| 642 | ||
| 643 | ||
