|
@@ -12,7 +12,7 @@ def ack_message(mode, platform, recv_msgs, consumer):
|
|
|
:param consumer:
|
|
:param consumer:
|
|
|
"""
|
|
"""
|
|
|
try:
|
|
try:
|
|
|
- receipt_handle_list = recv_msgs.receipt_handle
|
|
|
|
|
|
|
+ receipt_handle_list = [recv_msgs.receipt_handle]
|
|
|
consumer.ack_message(receipt_handle_list)
|
|
consumer.ack_message(receipt_handle_list)
|
|
|
Local.logger(platform, mode).info(
|
|
Local.logger(platform, mode).info(
|
|
|
f"Ack {len(receipt_handle_list)} Message Succeed.\n"
|
|
f"Ack {len(receipt_handle_list)} Message Succeed.\n"
|
