Innmind /
AMQP
| @@ 71-93 (lines=23) @@ | ||
| 68 | ); |
|
| 69 | } |
|
| 70 | ||
| 71 | public function consume(FrameChannel $channel, Consume $command): Frame |
|
| 72 | { |
|
| 73 | $consumerTag = ''; |
|
| 74 | ||
| 75 | if (!$command->shouldAutoGenerateConsumerTag()) { |
|
| 76 | $consumerTag = $command->consumerTag(); |
|
| 77 | } |
|
| 78 | ||
| 79 | return Frame::command( |
|
| 80 | $channel, |
|
| 81 | Methods::get('basic.consume'), |
|
| 82 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 83 | new ShortString(new Str($command->queue())), |
|
| 84 | new ShortString(new Str($consumerTag)), |
|
| 85 | new Bits( |
|
| 86 | !$command->isLocal(), |
|
| 87 | $command->shouldAutoAcknowledge(), |
|
| 88 | $command->isExclusive(), |
|
| 89 | !$command->shouldWait() |
|
| 90 | ), |
|
| 91 | $this->arguments($command->arguments()) |
|
| 92 | ); |
|
| 93 | } |
|
| 94 | ||
| 95 | public function get(FrameChannel $channel, Get $command): Frame |
|
| 96 | { |
|
| @@ 39-61 (lines=23) @@ | ||
| 36 | $this->translate = $translator; |
|
| 37 | } |
|
| 38 | ||
| 39 | public function declare(FrameChannel $channel, Declaration $command): Frame |
|
| 40 | { |
|
| 41 | $name = ''; |
|
| 42 | ||
| 43 | if (!$command->shouldAutoGenerateName()) { |
|
| 44 | $name = $command->name(); |
|
| 45 | } |
|
| 46 | ||
| 47 | return Frame::command( |
|
| 48 | $channel, |
|
| 49 | Methods::get('queue.declare'), |
|
| 50 | new UnsignedShortInteger(new Integer(0)), //ticket (reserved) |
|
| 51 | new ShortString(new Str($name)), |
|
| 52 | new Bits( |
|
| 53 | $command->isPassive(), |
|
| 54 | $command->isDurable(), |
|
| 55 | $command->isExclusive(), |
|
| 56 | $command->isAutoDeleted(), |
|
| 57 | !$command->shouldWait() |
|
| 58 | ), |
|
| 59 | $this->translate($command->arguments()) |
|
| 60 | ); |
|
| 61 | } |
|
| 62 | ||
| 63 | public function delete(FrameChannel $channel, Deletion $command): Frame |
|
| 64 | { |
|
