@@ -73,7 +73,7 @@ discard block |
||
73 | 73 | { |
74 | 74 | $attributes = $this->getQueue($queue)->get_attributes(); |
75 | 75 | |
76 | - return (int) $attributes->activeMsgNum; |
|
76 | + return (int)$attributes->activeMsgNum; |
|
77 | 77 | } |
78 | 78 | |
79 | 79 | /** |
@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | return $driver->publish_message($message->msgBody, [], $queue); |
125 | 125 | default: |
126 | 126 | throw new \InvalidArgumentException( |
127 | - 'Invalid CMQ topic filter: '.$this->topicOptions['filter'] |
|
127 | + 'Invalid CMQ topic filter: ' . $this->topicOptions['filter'] |
|
128 | 128 | ); |
129 | 129 | } |
130 | 130 | } |
@@ -175,7 +175,7 @@ discard block |
||
175 | 175 | $queue = $this->getQueue($queue); |
176 | 176 | $message = $queue->receive_message($this->queueOptions['polling_wait_seconds']); |
177 | 177 | } catch (CMQServerException $e) { |
178 | - if ((int) $e->getCode() === self::CMQ_QUEUE_NO_MESSAGE_CODE) { //ignore no message |
|
178 | + if ((int)$e->getCode() === self::CMQ_QUEUE_NO_MESSAGE_CODE) { //ignore no message |
|
179 | 179 | return; |
180 | 180 | } |
181 | 181 |