videlalvaro /
php-amqplib
| @@ 369-379 (lines=11) @@ | ||
| 366 | /** |
|
| 367 | * @return array |
|
| 368 | */ |
|
| 369 | public function queueBind($ticket = 1, $queue = '', $exchange, $routing_key = '', $nowait = false, $arguments = array()) |
|
| 370 | { |
|
| 371 | $args = new AMQPWriter(); |
|
| 372 | $args->write_short($ticket); |
|
| 373 | $args->write_shortstr($queue); |
|
| 374 | $args->write_shortstr($exchange); |
|
| 375 | $args->write_shortstr($routing_key); |
|
| 376 | $args->write_bits(array($nowait)); |
|
| 377 | $args->write_table(empty($arguments) ? array() : $arguments); |
|
| 378 | return array(50, 20, $args); |
|
| 379 | } |
|
| 380 | ||
| 381 | ||
| 382 | ||
| @@ 452-461 (lines=10) @@ | ||
| 449 | /** |
|
| 450 | * @return array |
|
| 451 | */ |
|
| 452 | public function queueUnbind($ticket = 1, $queue = '', $exchange, $routing_key = '', $arguments = array()) |
|
| 453 | { |
|
| 454 | $args = new AMQPWriter(); |
|
| 455 | $args->write_short($ticket); |
|
| 456 | $args->write_shortstr($queue); |
|
| 457 | $args->write_shortstr($exchange); |
|
| 458 | $args->write_shortstr($routing_key); |
|
| 459 | $args->write_table(empty($arguments) ? array() : $arguments); |
|
| 460 | return array(50, 50, $args); |
|
| 461 | } |
|
| 462 | ||
| 463 | ||
| 464 | ||
| @@ 337-347 (lines=11) @@ | ||
| 334 | /** |
|
| 335 | * @return array |
|
| 336 | */ |
|
| 337 | public function exchangeBind($ticket = 0, $destination, $source, $routing_key = '', $nowait = false, $arguments = array()) |
|
| 338 | { |
|
| 339 | $args = new AMQPWriter(); |
|
| 340 | $args->write_short($ticket); |
|
| 341 | $args->write_shortstr($destination); |
|
| 342 | $args->write_shortstr($source); |
|
| 343 | $args->write_shortstr($routing_key); |
|
| 344 | $args->write_bits(array($nowait)); |
|
| 345 | $args->write_table(empty($arguments) ? array() : $arguments); |
|
| 346 | return array(40, 30, $args); |
|
| 347 | } |
|
| 348 | ||
| 349 | ||
| 350 | ||
| @@ 366-376 (lines=11) @@ | ||
| 363 | /** |
|
| 364 | * @return array |
|
| 365 | */ |
|
| 366 | public function exchangeUnbind($ticket = 0, $destination, $source, $routing_key = '', $nowait = false, $arguments = array()) |
|
| 367 | { |
|
| 368 | $args = new AMQPWriter(); |
|
| 369 | $args->write_short($ticket); |
|
| 370 | $args->write_shortstr($destination); |
|
| 371 | $args->write_shortstr($source); |
|
| 372 | $args->write_shortstr($routing_key); |
|
| 373 | $args->write_bits(array($nowait)); |
|
| 374 | $args->write_table(empty($arguments) ? array() : $arguments); |
|
| 375 | return array(40, 40, $args); |
|
| 376 | } |
|
| 377 | ||
| 378 | ||
| 379 | ||
| @@ 425-435 (lines=11) @@ | ||
| 422 | /** |
|
| 423 | * @return array |
|
| 424 | */ |
|
| 425 | public function queueBind($ticket = 0, $queue = '', $exchange, $routing_key = '', $nowait = false, $arguments = array()) |
|
| 426 | { |
|
| 427 | $args = new AMQPWriter(); |
|
| 428 | $args->write_short($ticket); |
|
| 429 | $args->write_shortstr($queue); |
|
| 430 | $args->write_shortstr($exchange); |
|
| 431 | $args->write_shortstr($routing_key); |
|
| 432 | $args->write_bits(array($nowait)); |
|
| 433 | $args->write_table(empty($arguments) ? array() : $arguments); |
|
| 434 | return array(50, 20, $args); |
|
| 435 | } |
|
| 436 | ||
| 437 | ||
| 438 | ||
| @@ 508-517 (lines=10) @@ | ||
| 505 | /** |
|
| 506 | * @return array |
|
| 507 | */ |
|
| 508 | public function queueUnbind($ticket = 0, $queue = '', $exchange, $routing_key = '', $arguments = array()) |
|
| 509 | { |
|
| 510 | $args = new AMQPWriter(); |
|
| 511 | $args->write_short($ticket); |
|
| 512 | $args->write_shortstr($queue); |
|
| 513 | $args->write_shortstr($exchange); |
|
| 514 | $args->write_shortstr($routing_key); |
|
| 515 | $args->write_table(empty($arguments) ? array() : $arguments); |
|
| 516 | return array(50, 50, $args); |
|
| 517 | } |
|
| 518 | ||
| 519 | ||
| 520 | ||
