@@ 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 |