Innmind /
AMQP
| @@ 67-80 (lines=14) @@ | ||
| 64 | ); |
|
| 65 | } |
|
| 66 | ||
| 67 | public function bind(FrameChannel $channel, Binding $command): Frame |
|
| 68 | { |
|
| 69 | return new Frame( |
|
| 70 | Type::method(), |
|
| 71 | $channel, |
|
| 72 | Methods::get('queue.bind'), |
|
| 73 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 74 | new ShortString(new Str($command->queue())), |
|
| 75 | new ShortString(new Str($command->exchange())), |
|
| 76 | new ShortString(new Str($command->routingKey())), |
|
| 77 | new Bits(!$command->shouldWait()), |
|
| 78 | new Table(new Map('string', Value::class)) //todo: use $command->arguments() |
|
| 79 | ); |
|
| 80 | } |
|
| 81 | ||
| 82 | public function unbind(FrameChannel $channel, Unbinding $command): Frame |
|
| 83 | { |
|
| @@ 82-94 (lines=13) @@ | ||
| 79 | ); |
|
| 80 | } |
|
| 81 | ||
| 82 | public function unbind(FrameChannel $channel, Unbinding $command): Frame |
|
| 83 | { |
|
| 84 | return new Frame( |
|
| 85 | Type::method(), |
|
| 86 | $channel, |
|
| 87 | Methods::get('queue.unbind'), |
|
| 88 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 89 | new ShortString(new Str($command->queue())), |
|
| 90 | new ShortString(new Str($command->exchange())), |
|
| 91 | new ShortString(new Str($command->routingKey())), |
|
| 92 | new Table(new Map('string', Value::class)) //todo: use $command->arguments() |
|
| 93 | ); |
|
| 94 | } |
|
| 95 | ||
| 96 | public function purge(FrameChannel $channel, Purge $command): Frame |
|
| 97 | { |
|
