src/Objects/Exchange.php 1 location
|
@@ 93-99 (lines=7) @@
|
90 |
|
* @param string $name |
91 |
|
* @param string $type direct, topic, headers or fanout |
92 |
|
*/ |
93 |
|
public function __construct(Client $client, $name, $type) |
94 |
|
{ |
95 |
|
$this->client = $client; |
96 |
|
$this->client->register($this); |
97 |
|
$this->name = $name; |
98 |
|
$this->type = $type; |
99 |
|
} |
100 |
|
|
101 |
|
/** |
102 |
|
* Get the exchange name. |
src/Objects/Queue.php 1 location
|
@@ 140-146 (lines=7) @@
|
137 |
|
* @param string $name |
138 |
|
* @param ConsumerInterface[] $consumers |
139 |
|
*/ |
140 |
|
public function __construct(Client $client, $name, array $consumers = []) |
141 |
|
{ |
142 |
|
$this->client = $client; |
143 |
|
$this->client->register($this); |
144 |
|
$this->name = $name; |
145 |
|
$this->consumers = $consumers; |
146 |
|
} |
147 |
|
|
148 |
|
/** |
149 |
|
* Get queue name. |