treehouselabs /
queue
| @@ 51-60 (lines=10) @@ | ||
| 48 | /** |
|
| 49 | * @inheritdoc |
|
| 50 | */ |
|
| 51 | public function basicQos($prefetchSize, $prefetchCount) |
|
| 52 | { |
|
| 53 | try { |
|
| 54 | return $this->delegate->qos($prefetchSize, $prefetchCount); |
|
| 55 | } catch (\AMQPChannelException $e) { |
|
| 56 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
| 57 | } catch (\AMQPConnectionException $e) { |
|
| 58 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
| 59 | } |
|
| 60 | } |
|
| 61 | ||
| 62 | /** |
|
| 63 | * @inheritdoc |
|
| @@ 65-74 (lines=10) @@ | ||
| 62 | /** |
|
| 63 | * @inheritdoc |
|
| 64 | */ |
|
| 65 | public function startTransaction() |
|
| 66 | { |
|
| 67 | try { |
|
| 68 | return $this->delegate->startTransaction(); |
|
| 69 | } catch (\AMQPChannelException $e) { |
|
| 70 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
| 71 | } catch (\AMQPConnectionException $e) { |
|
| 72 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
| 73 | } |
|
| 74 | } |
|
| 75 | ||
| 76 | /** |
|
| 77 | * @inheritdoc |
|
| @@ 79-88 (lines=10) @@ | ||
| 76 | /** |
|
| 77 | * @inheritdoc |
|
| 78 | */ |
|
| 79 | public function commitTransaction() |
|
| 80 | { |
|
| 81 | try { |
|
| 82 | return $this->delegate->commitTransaction(); |
|
| 83 | } catch (\AMQPChannelException $e) { |
|
| 84 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
| 85 | } catch (\AMQPConnectionException $e) { |
|
| 86 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
| 87 | } |
|
| 88 | } |
|
| 89 | ||
| 90 | /** |
|
| 91 | * @inheritdoc |
|
| @@ 93-102 (lines=10) @@ | ||
| 90 | /** |
|
| 91 | * @inheritdoc |
|
| 92 | */ |
|
| 93 | public function rollbackTransaction() |
|
| 94 | { |
|
| 95 | try { |
|
| 96 | return $this->delegate->rollbackTransaction(); |
|
| 97 | } catch (\AMQPChannelException $e) { |
|
| 98 | throw new ChannelException($e->getMessage(), $e->getCode(), $e); |
|
| 99 | } catch (\AMQPConnectionException $e) { |
|
| 100 | throw new ConnectionException($e->getMessage(), $e->getCode(), $e); |
|
| 101 | } |
|
| 102 | } |
|
| 103 | ||
| 104 | /** |
|
| 105 | * @inheritdoc |
|
