|
@@ -124,18 +124,18 @@ |
|
|
block discarded – undo |
|
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
|
); |
Please login to merge, or discard this patch.