@@ 114-127 (lines=14) @@ | ||
111 | ); |
|
112 | } |
|
113 | ||
114 | public function bind() |
|
115 | { |
|
116 | if (!isset($this->attributes['bind'])) { |
|
117 | return; |
|
118 | } |
|
119 | foreach ($this->attributes['bind'] as $bindItem) { |
|
120 | $this->getChannel() |
|
121 | ->queue_bind( |
|
122 | $bindItem['queue'], |
|
123 | $this->attributes['name'], |
|
124 | $bindItem['routing_key'] |
|
125 | ); |
|
126 | } |
|
127 | } |
|
128 | ||
129 | /** |
|
130 | * Delete the queue |
@@ 171-183 (lines=13) @@ | ||
168 | ); |
|
169 | } |
|
170 | ||
171 | public function bind() |
|
172 | { |
|
173 | if (isset($this->attributes['bind'])) { |
|
174 | foreach ($this->attributes['bind'] as $bindItem) { |
|
175 | $this->getChannel() |
|
176 | ->queue_bind( |
|
177 | $this->attributes['name'], |
|
178 | $bindItem['exchange'], |
|
179 | $bindItem['routing_key'] |
|
180 | ); |
|
181 | } |
|
182 | } |
|
183 | } |
|
184 | ||
185 | /** |
|
186 | * Delete the queue |