| @@ 88-102 (lines=15) @@ | ||
| 85 | return $this; |
|
| 86 | } |
|
| 87 | ||
| 88 | public function declareQueue(Queue $queue) : ChannelInterface |
|
| 89 | { |
|
| 90 | $this->channel->queue_declare( |
|
| 91 | $queue->getQueueName(), |
|
| 92 | $queue->isPassive(), |
|
| 93 | $queue->isDurable(), |
|
| 94 | $queue->isExclusive(), |
|
| 95 | $queue->isAutoDelete(), |
|
| 96 | $queue->isNoWait(), |
|
| 97 | $queue->getArguments(), |
|
| 98 | $queue->getTicket() |
|
| 99 | ); |
|
| 100 | ||
| 101 | return $this; |
|
| 102 | } |
|
| 103 | ||
| 104 | public function bindQueue(Queue $queue) : ChannelInterface |
|
| 105 | { |
|
| @@ 118-133 (lines=16) @@ | ||
| 115 | return $this; |
|
| 116 | } |
|
| 117 | ||
| 118 | public function declareExchange(Exchange $exchange) : ChannelInterface |
|
| 119 | { |
|
| 120 | $this->channel->exchange_declare( |
|
| 121 | $exchange->getExchange(), |
|
| 122 | $exchange->getType(), |
|
| 123 | $exchange->isPassive(), |
|
| 124 | $exchange->isDurable(), |
|
| 125 | $exchange->isAutoDelete(), |
|
| 126 | $exchange->isInternal(), |
|
| 127 | $exchange->isNoWait(), |
|
| 128 | $exchange->getArguments(), |
|
| 129 | $exchange->getTicket() |
|
| 130 | ); |
|
| 131 | ||
| 132 | return $this; |
|
| 133 | } |
|
| 134 | ||
| 135 | /** |
|
| 136 | * @return array |
|