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