@@ 155-166 (lines=12) @@ | ||
152 | /** |
|
153 | * @inheritdoc |
|
154 | */ |
|
155 | public function delete($exchangeName = null, $flags = null) |
|
156 | { |
|
157 | try { |
|
158 | return $this->delegate->delete($exchangeName, self::convertToDelegateFlags($flags)); |
|
159 | } catch (\AMQPExchangeException $e) { |
|
160 | throw new ExchangeException($e->getMessage(), $e->getCode(), $e); |
|
161 | } catch (\AMQPChannelException $e) { |
|
162 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
163 | } catch (\AMQPConnectionException $e) { |
|
164 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
165 | } |
|
166 | } |
|
167 | ||
168 | /** |
|
169 | * @inheritdoc |
|
@@ 171-182 (lines=12) @@ | ||
168 | /** |
|
169 | * @inheritdoc |
|
170 | */ |
|
171 | public function publish($message, $routingKey = null, $flags = null, array $attributes = []) |
|
172 | { |
|
173 | try { |
|
174 | return $this->delegate->publish($message, $routingKey, self::convertToDelegateFlags($flags), $attributes); |
|
175 | } catch (\AMQPExchangeException $e) { |
|
176 | throw new ExchangeException($e->getMessage(), $e->getCode(), $e); |
|
177 | } catch (\AMQPChannelException $e) { |
|
178 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
179 | } catch (\AMQPConnectionException $e) { |
|
180 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
181 | } |
|
182 | } |
|
183 | ||
184 | /** |
|
185 | * @inheritdoc |