@@ -74,8 +74,7 @@ |
||
74 | 74 | $credentials['ssl'], |
75 | 75 | $credentials['options'] |
76 | 76 | ); |
77 | - } |
|
78 | - else { |
|
77 | + } else { |
|
79 | 78 | $defaultOptions = [ |
80 | 79 | 'insist' => FALSE, |
81 | 80 | 'login_method' => 'AMQPLAIN', |
@@ -172,8 +172,7 @@ |
||
172 | 172 | $options['arguments'] ?? NULL, |
173 | 173 | $options['ticket'] ?? NULL |
174 | 174 | ); |
175 | - } |
|
176 | - catch (AMQPProtocolChannelException $e) { |
|
175 | + } catch (AMQPProtocolChannelException $e) { |
|
177 | 176 | return NULL; |
178 | 177 | } |
179 | 178 |
@@ -49,8 +49,7 @@ |
||
49 | 49 | $channel->basic_publish($item, $exchange, $routingKey); |
50 | 50 | $this->logger->debug('Item sent to queue %queue', $loggerArgs); |
51 | 51 | $result = TRUE; |
52 | - } |
|
53 | - catch (\Exception $e) { |
|
52 | + } catch (\Exception $e) { |
|
54 | 53 | $this->logger->error('Failed to send item to queue %queue: @message', $loggerArgs + [ |
55 | 54 | '@message' => $e->getMessage(), |
56 | 55 | ]); |