| @@ 35-44 (lines=10) @@ | ||
| 32 | ||
| 33 | final class Basic implements BasicInterface |
|
| 34 | { |
|
| 35 | public function ack(FrameChannel $channel, Ack $command): Frame |
|
| 36 | { |
|
| 37 | return new Frame( |
|
| 38 | Type::method(), |
|
| 39 | $channel, |
|
| 40 | Methods::get('basic.ack'), |
|
| 41 | new UnsignedLongLongInteger(new Integer($command->deliveryTag())), |
|
| 42 | new Bits($command->isMultiple()) |
|
| 43 | ); |
|
| 44 | } |
|
| 45 | ||
| 46 | public function cancel(FrameChannel $channel, Cancel $command): Frame |
|
| 47 | { |
|
| @@ 128-137 (lines=10) @@ | ||
| 125 | ); |
|
| 126 | } |
|
| 127 | ||
| 128 | public function reject(FrameChannel $channel, Reject $command): Frame |
|
| 129 | { |
|
| 130 | return new Frame( |
|
| 131 | Type::method(), |
|
| 132 | $channel, |
|
| 133 | Methods::get('basic.reject'), |
|
| 134 | new UnsignedLongLongInteger(new Integer($command->deliveryTag())), |
|
| 135 | new Bits($command->shouldRequeue()) |
|
| 136 | ); |
|
| 137 | } |
|
| 138 | } |
|
| 139 | ||