Skip to content

Commit feade10

Browse files
committed
Added 'requeue=False' argument when nacking message
1 parent 1a0057b commit feade10

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/murfey/server/__init__.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2988,7 +2988,8 @@ def feedback_callback(header: dict, message: dict) -> None:
29882988
if result:
29892989
_transport_object.transport.ack(header)
29902990
else:
2991-
_transport_object.transport.nack(header)
2991+
# Send it directly to DLQ without trying to rerun it
2992+
_transport_object.transport.nack(header, requeue=False)
29922993
return None
29932994
if _transport_object:
29942995
_transport_object.transport.nack(header, requeue=False)

0 commit comments

Comments
 (0)