daikon-cqrs /
rabbitmq3-adapter
| @@ 95-110 (lines=16) @@ | ||
| 92 | ]); |
|
| 93 | } |
|
| 94 | ||
| 95 | private function bindExchange( |
|
| 96 | string $source, |
|
| 97 | string $dest, |
|
| 98 | string $routingKey = '', |
|
| 99 | bool $noWait = false, |
|
| 100 | array $arguments = [] |
|
| 101 | ): void { |
|
| 102 | $uri = sprintf('/api/bindings/%s/e/%s/e/%s', $this->getVhost(), $source, $dest); |
|
| 103 | $this->connector->getConnection()->post($uri, [ |
|
| 104 | 'body' => json_encode([ |
|
| 105 | 'routing_key' => $routingKey, |
|
| 106 | 'nowait' => $noWait, |
|
| 107 | 'arguments' => $arguments |
|
| 108 | ]) |
|
| 109 | ]); |
|
| 110 | } |
|
| 111 | ||
| 112 | private function deleteExchange(string $exchange): void |
|
| 113 | { |
|
| @@ 140-155 (lines=16) @@ | ||
| 137 | ]); |
|
| 138 | } |
|
| 139 | ||
| 140 | private function bindQueue( |
|
| 141 | string $queue, |
|
| 142 | string $exchange, |
|
| 143 | string $routingKey = '', |
|
| 144 | bool $noWait = false, |
|
| 145 | array $arguments = [] |
|
| 146 | ): void { |
|
| 147 | $uri = sprintf('/api/bindings/%s/e/%s/q/%s', $this->getVhost(), $exchange, $queue); |
|
| 148 | $this->connector->getConnection()->post($uri, [ |
|
| 149 | 'body' => json_encode([ |
|
| 150 | 'routing_key' => $routingKey, |
|
| 151 | 'nowait' => $noWait, |
|
| 152 | 'arguments' => $arguments |
|
| 153 | ]) |
|
| 154 | ]); |
|
| 155 | } |
|
| 156 | ||
| 157 | private function deleteQueue(string $queue): void |
|
| 158 | { |
|
