notePushFailure: (
record?: any,
why?: any,
nowMs?: any,
) => { declaredDead: boolean; moved: number } = ...
Type Declaration
-
- (record?: any, why?: any, nowMs?: any): { declaredDead: boolean; moved: number }
-
Parameters
Optionalrecord: any
Optionalwhy: any
OptionalnowMs: any
Returns { declaredDead: boolean; moved: number }
{ declaredDead, moved }
Records a failed push, declaring the stream dead (and moving its queue to the dead letters) when nothing has been delivered for the timeout.