@@ -124,18 +124,18 @@ |
||
124 | 124 | $triesNum = 10; |
125 | 125 | $headers = $msg->get('application_headers')->getNativeData(); |
126 | 126 | $retryCount = $this->getRetryCount($headers); |
127 | - $retry = ($retryCount < $triesNum - 1); |
|
128 | - $resheduleInS = (5 * $retryCount + 10); |
|
127 | + $retry = ($retryCount < $triesNum-1); |
|
128 | + $resheduleInS = (5 * $retryCount+10); |
|
129 | 129 | |
130 | 130 | $this->logger->error( |
131 | 131 | sprintf( |
132 | - 'Error while executing processor (retry count: %d - %s): %s', $retryCount + 1, $retry ? 'retry in ' . $resheduleInS . 's' : 'reject', $e->getMessage() |
|
132 | + 'Error while executing processor (retry count: %d - %s): %s', $retryCount+1, $retry ? 'retry in '.$resheduleInS.'s' : 'reject', $e->getMessage() |
|
133 | 133 | ), array($e->getTraceAsString(), $this, $processor) |
134 | 134 | ); |
135 | 135 | |
136 | 136 | if ($retry) { |
137 | 137 | $this->rescheduleProducer->publish( |
138 | - $msg->body, (string)$msg->delivery_info['routing_key'], array_merge( |
|
138 | + $msg->body, (string) $msg->delivery_info['routing_key'], array_merge( |
|
139 | 139 | $msg->get_properties(), array('expiration' => $resheduleInS * 1000) |
140 | 140 | ) |
141 | 141 | ); |