|
@@ -152,6 +152,7 @@ class AgentService:
|
|
|
if message:
|
|
|
try:
|
|
|
self.process_single_message(message)
|
|
|
+ self.receive_queue.ack(message)
|
|
|
except NoRetryException as e:
|
|
|
logger.error("Error processing message and skip retry: {}".format(e))
|
|
|
self.receive_queue.ack(message)
|