| @@ 43-52 (lines=10) @@ | ||
| 40 | $this->translate = $translator; |
|
| 41 | } |
|
| 42 | ||
| 43 | public function ack(FrameChannel $channel, Ack $command): Frame |
|
| 44 | { |
|
| 45 | return new Frame( |
|
| 46 | Type::method(), |
|
| 47 | $channel, |
|
| 48 | Methods::get('basic.ack'), |
|
| 49 | new UnsignedLongLongInteger(new Integer($command->deliveryTag())), |
|
| 50 | new Bits($command->isMultiple()) |
|
| 51 | ); |
|
| 52 | } |
|
| 53 | ||
| 54 | public function cancel(FrameChannel $channel, Cancel $command): Frame |
|
| 55 | { |
|
| @@ 152-161 (lines=10) @@ | ||
| 149 | ); |
|
| 150 | } |
|
| 151 | ||
| 152 | public function reject(FrameChannel $channel, Reject $command): Frame |
|
| 153 | { |
|
| 154 | return new Frame( |
|
| 155 | Type::method(), |
|
| 156 | $channel, |
|
| 157 | Methods::get('basic.reject'), |
|
| 158 | new UnsignedLongLongInteger(new Integer($command->deliveryTag())), |
|
| 159 | new Bits($command->shouldRequeue()) |
|
| 160 | ); |
|
| 161 | } |
|
| 162 | } |
|
| 163 | ||