File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -2952,13 +2952,12 @@ def feedback_callback(header: dict, message: dict) -> None:
29522952 register_lif_preprocessing_result (message , murfey_db )
29532953 if _transport_object :
29542954 _transport_object .transport .ack (header )
2955- # When a message is received, it goes into unacked
2956- # When it's acked, it gets removed from the queue
2957- # When it's nacked, it eventually ends up in the DLQ
2955+ return None
29582956 elif message ["register" ] == "register_tiff_preprocessing_result" :
29592957 register_tiff_preprocessing_result (message , murfey_db )
29602958 if _transport_object :
29612959 _transport_object .transport .ack (header )
2960+ return None
29622961 if _transport_object :
29632962 _transport_object .transport .nack (header , requeue = False )
29642963 return None
You can’t perform that action at this time.
0 commit comments