Innmind /
AMQP
| @@ 106-116 (lines=11) @@ | ||
| 103 | ); |
|
| 104 | } |
|
| 105 | ||
| 106 | public function qos(FrameChannel $channel, Qos $command): Frame |
|
| 107 | { |
|
| 108 | return new Frame( |
|
| 109 | Type::method(), |
|
| 110 | $channel, |
|
| 111 | Methods::get('basic.qos'), |
|
| 112 | new UnsignedLongInteger(new Integer($command->prefetchSize())), |
|
| 113 | new UnsignedShortInteger(new Integer($command->prefetchCount())), |
|
| 114 | new Bits($command->isGlobal()) |
|
| 115 | ); |
|
| 116 | } |
|
| 117 | ||
| 118 | public function recover(FrameChannel $channel, Recover $command): Frame |
|
| 119 | { |
|
| @@ 96-106 (lines=11) @@ | ||
| 93 | ); |
|
| 94 | } |
|
| 95 | ||
| 96 | public function purge(FrameChannel $channel, Purge $command): Frame |
|
| 97 | { |
|
| 98 | return new Frame( |
|
| 99 | Type::method(), |
|
| 100 | $channel, |
|
| 101 | Methods::get('queue.purge'), |
|
| 102 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 103 | new ShortString(new Str($command->name())), |
|
| 104 | new Bits(!$command->shouldWait()) |
|
| 105 | ); |
|
| 106 | } |
|
| 107 | } |
|
| 108 | ||
