Innmind /
AMQP
| @@ 104-111 (lines=8) @@ | ||
| 101 | $routingKey |
|
| 102 | ); |
|
| 103 | ||
| 104 | if (!$this->command->shouldAutoAcknowledge()) { |
|
| 105 | $this->connection->send( |
|
| 106 | $this->connection->protocol()->basic()->ack( |
|
| 107 | $this->channel, |
|
| 108 | new Ack($deliveryTag) |
|
| 109 | ) |
|
| 110 | ); |
|
| 111 | } |
|
| 112 | } catch (Reject $e) { |
|
| 113 | $this->reject($deliveryTag); |
|
| 114 | } catch (Requeue $e) { |
|
| @@ 71-78 (lines=8) @@ | ||
| 68 | $this->messageCount |
|
| 69 | ); |
|
| 70 | ||
| 71 | if (!$this->command->shouldAutoAcknowledge()) { |
|
| 72 | $this |
|
| 73 | ->connection |
|
| 74 | ->send($this->connection->protocol()->basic()->ack( |
|
| 75 | $this->channel, |
|
| 76 | new Ack($this->deliveryTag) |
|
| 77 | )); |
|
| 78 | } |
|
| 79 | ||
| 80 | $this->consumed = true; |
|
| 81 | } catch (Reject $e) { |
|
