Skip to content

Commit a00fce9

Browse files
authored
HOTFIX
Duplicate messages on invalid header
1 parent 90a2128 commit a00fce9

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

services/servicebus/service.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -839,7 +839,6 @@ def datagram_received(derived, data: bytes, addr):
839839
seq = int(seq_b)
840840
except Exception as e:
841841
self.log.debug("Invalid split header %s – treating as normal", parts)
842-
derived._handle_raw_payload(data)
843842
else:
844843
# 2️⃣ Store fragment and see if we are finished
845844
loop = asyncio.get_running_loop()

0 commit comments

Comments
 (0)