@@ 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 |