Skip already processed messages
This commit is contained in:
parent
4019693363
commit
211381a9a8
@ -257,6 +257,9 @@ class Session:
|
|||||||
|
|
||||||
for i in messages:
|
for i in messages:
|
||||||
if i.seq_no % 2 != 0:
|
if i.seq_no % 2 != 0:
|
||||||
|
if i.msg_id in self.pending_acks:
|
||||||
|
continue
|
||||||
|
else:
|
||||||
self.pending_acks.add(i.msg_id)
|
self.pending_acks.add(i.msg_id)
|
||||||
|
|
||||||
# log.debug("{}".format(type(i.body)))
|
# log.debug("{}".format(type(i.body)))
|
||||||
|
Loading…
Reference in New Issue
Block a user