skolodyazhnyy /
butter-amqplib
| @@ 540-549 (lines=10) @@ | ||
| 537 | /** |
|
| 538 | * @param BasicAck $frame |
|
| 539 | */ |
|
| 540 | private function onBasicAck(BasicAck $frame) |
|
| 541 | { |
|
| 542 | if (!$this->confirmCallable) { |
|
| 543 | throw new \RuntimeException( |
|
| 544 | 'Something is wrong: channel is in confirm mode, but confirm callable is not set' |
|
| 545 | ); |
|
| 546 | } |
|
| 547 | ||
| 548 | call_user_func($this->confirmCallable, new Confirm(true, $frame->getDeliveryTag(), $frame->isMultiple())); |
|
| 549 | } |
|
| 550 | ||
| 551 | /** |
|
| 552 | * @param BasicNack $frame |
|
| @@ 554-563 (lines=10) @@ | ||
| 551 | /** |
|
| 552 | * @param BasicNack $frame |
|
| 553 | */ |
|
| 554 | private function onBasicNack(BasicNack $frame) |
|
| 555 | { |
|
| 556 | if (!$this->confirmCallable) { |
|
| 557 | throw new \RuntimeException( |
|
| 558 | 'Something is wrong: channel is in confirm mode, but confirm callable is not set' |
|
| 559 | ); |
|
| 560 | } |
|
| 561 | ||
| 562 | call_user_func($this->confirmCallable, new Confirm(false, $frame->getDeliveryTag(), $frame->isMultiple())); |
|
| 563 | } |
|
| 564 | ||
| 565 | /** |
|
| 566 | * @param BasicCancel $frame |
|
