Innmind /
AMQP
| @@ 150-159 (lines=10) @@ | ||
| 147 | ); |
|
| 148 | } |
|
| 149 | ||
| 150 | public function qos(FrameChannel $channel, Qos $command): Frame |
|
| 151 | { |
|
| 152 | return Frame::command( |
|
| 153 | $channel, |
|
| 154 | Methods::get('basic.qos'), |
|
| 155 | new UnsignedLongInteger(new Integer($command->prefetchSize())), |
|
| 156 | new UnsignedShortInteger(new Integer($command->prefetchCount())), |
|
| 157 | new Bits($command->isGlobal()) |
|
| 158 | ); |
|
| 159 | } |
|
| 160 | ||
| 161 | public function recover(FrameChannel $channel, Recover $command): Frame |
|
| 162 | { |
|
| @@ 105-114 (lines=10) @@ | ||
| 102 | ); |
|
| 103 | } |
|
| 104 | ||
| 105 | public function purge(FrameChannel $channel, Purge $command): Frame |
|
| 106 | { |
|
| 107 | return Frame::command( |
|
| 108 | $channel, |
|
| 109 | Methods::get('queue.purge'), |
|
| 110 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 111 | new ShortString(new Str($command->name())), |
|
| 112 | new Bits(!$command->shouldWait()) |
|
| 113 | ); |
|
| 114 | } |
|
| 115 | ||
| 116 | /** |
|
| 117 | * @param MapInterface<string, mixed> $arguments |
|
