@@ -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 | |