| @@ 78-90 (lines=13) @@ | ||
| 75 | ); |
|
| 76 | } |
|
| 77 | ||
| 78 | public function bind(FrameChannel $channel, Binding $command): Frame |
|
| 79 | { |
|
| 80 | return Frame::command( |
|
| 81 | $channel, |
|
| 82 | Methods::get('queue.bind'), |
|
| 83 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 84 | new ShortString(new Str($command->queue())), |
|
| 85 | new ShortString(new Str($command->exchange())), |
|
| 86 | new ShortString(new Str($command->routingKey())), |
|
| 87 | new Bits(!$command->shouldWait()), |
|
| 88 | $this->translate($command->arguments()) |
|
| 89 | ); |
|
| 90 | } |
|
| 91 | ||
| 92 | public function unbind(FrameChannel $channel, Unbinding $command): Frame |
|
| 93 | { |
|
| @@ 92-103 (lines=12) @@ | ||
| 89 | ); |
|
| 90 | } |
|
| 91 | ||
| 92 | public function unbind(FrameChannel $channel, Unbinding $command): Frame |
|
| 93 | { |
|
| 94 | return Frame::command( |
|
| 95 | $channel, |
|
| 96 | Methods::get('queue.unbind'), |
|
| 97 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 98 | new ShortString(new Str($command->queue())), |
|
| 99 | new ShortString(new Str($command->exchange())), |
|
| 100 | new ShortString(new Str($command->routingKey())), |
|
| 101 | $this->translate($command->arguments()) |
|
| 102 | ); |
|
| 103 | } |
|
| 104 | ||
| 105 | public function purge(FrameChannel $channel, Purge $command): Frame |
|
| 106 | { |
|