File tree 1 file changed +19
-0
lines changed
1 file changed +19
-0
lines changed Original file line number Diff line number Diff line change @@ -826,8 +826,22 @@ export class SharedQueueConsumer {
826
826
return ;
827
827
}
828
828
829
+ logger . debug ( "RESUME_AFTER_DEPENDENCY_WITH_ACK restored checkpoint" , {
830
+ queueMessage : message . data ,
831
+ messageId : message . messageId ,
832
+ checkpoint,
833
+ } ) ;
834
+
829
835
this . #doMoreWork( ) ;
830
836
return ;
837
+ } else {
838
+ logger . debug (
839
+ "RESUME_AFTER_DEPENDENCY_WITH_ACK run is frozen without last checkpoint event" ,
840
+ {
841
+ queueMessage : message . data ,
842
+ messageId : message . messageId ,
843
+ }
844
+ ) ;
831
845
}
832
846
} catch ( e ) {
833
847
if ( e instanceof Error ) {
@@ -847,6 +861,11 @@ export class SharedQueueConsumer {
847
861
}
848
862
}
849
863
864
+ logger . debug ( "RESUME_AFTER_DEPENDENCY_WITH_ACK retrying" , {
865
+ queueMessage : message . data ,
866
+ messageId : message . messageId ,
867
+ } ) ;
868
+
850
869
await this . #nackAndDoMoreWork( message . messageId , this . _options . nextTickInterval , 5_000 ) ;
851
870
return ;
852
871
} catch ( e ) {
You can’t perform that action at this time.
0 commit comments