needle-project /
laravel-rabbitmq
| @@ 100-112 (lines=13) @@ | ||
| 97 | /** |
|
| 98 | * Create the Queue |
|
| 99 | */ |
|
| 100 | public function create() |
|
| 101 | { |
|
| 102 | $this->getChannel() |
|
| 103 | ->exchange_declare( |
|
| 104 | $this->attributes['name'], |
|
| 105 | $this->attributes['exchange_type'], |
|
| 106 | $this->attributes['passive'], |
|
| 107 | $this->attributes['durable'], |
|
| 108 | $this->attributes['auto_delete'], |
|
| 109 | $this->attributes['internal'], |
|
| 110 | $this->attributes['nowait'] |
|
| 111 | ); |
|
| 112 | } |
|
| 113 | ||
| 114 | public function bind() |
|
| 115 | { |
|
| @@ 158-170 (lines=13) @@ | ||
| 155 | /** |
|
| 156 | * Create the Queue |
|
| 157 | */ |
|
| 158 | public function create() |
|
| 159 | { |
|
| 160 | $this->getChannel() |
|
| 161 | ->queue_declare( |
|
| 162 | $this->attributes['name'], |
|
| 163 | $this->attributes['passive'], |
|
| 164 | $this->attributes['durable'], |
|
| 165 | $this->attributes['exclusive'], |
|
| 166 | $this->attributes['auto_delete'], |
|
| 167 | $this->attributes['internal'], |
|
| 168 | $this->attributes['nowait'] |
|
| 169 | ); |
|
| 170 | } |
|
| 171 | ||
| 172 | public function bind() |
|
| 173 | { |
|
