treehouselabs /
queue
| @@ 107-118 (lines=12) @@ | ||
| 104 | /** |
|
| 105 | * @inheritdoc |
|
| 106 | */ |
|
| 107 | public function bind($exchangeName, $routingKey, array $arguments = []) |
|
| 108 | { |
|
| 109 | try { |
|
| 110 | return $this->delegate->bind($exchangeName, $routingKey, $arguments); |
|
| 111 | } catch (\AMQPExchangeException $e) { |
|
| 112 | throw new ExchangeException($e->getMessage(), $e->getCode(), $e); |
|
| 113 | } catch (\AMQPChannelException $e) { |
|
| 114 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
| 115 | } catch (\AMQPConnectionException $e) { |
|
| 116 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
| 117 | } |
|
| 118 | } |
|
| 119 | ||
| 120 | /** |
|
| 121 | * @inheritdoc |
|
| @@ 123-134 (lines=12) @@ | ||
| 120 | /** |
|
| 121 | * @inheritdoc |
|
| 122 | */ |
|
| 123 | public function unbind($exchangeName, $routingKey, array $arguments = []) |
|
| 124 | { |
|
| 125 | try { |
|
| 126 | return $this->delegate->unbind($exchangeName, $routingKey, $arguments); |
|
| 127 | } catch (\AMQPExchangeException $e) { |
|
| 128 | throw new ExchangeException($e->getMessage(), $e->getCode(), $e); |
|
| 129 | } catch (\AMQPChannelException $e) { |
|
| 130 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
| 131 | } catch (\AMQPConnectionException $e) { |
|
| 132 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
| 133 | } |
|
| 134 | } |
|
| 135 | ||
| 136 | /** |
|
| 137 | * @inheritdoc |
|
