Consumer stopped polling for messages no error logs

[akash-rajput]

I'm using @ssut/[email protected] with a FIFO queue. After running fine for few days the consumer stopped polling for messages without any error logs. The containing service has been up and running without any issues. None of the error handlers triggered.

  @SqsConsumerEventHandler(
    /** name: */ sqsQueueName,
    /** eventName: */ 'error',
  )
  public onError(error: Error, message: AWS.SQS.Message) {
    this.logger.log(message, 'Error message');
    this.logger.error(error, 'Error Exception');
  }

  @SqsConsumerEventHandler(
    /** name: */ sqsQueueName,
    /** eventName: */ 'processing_error',
  )
  public onProcessingError(error: Error, message: AWS.SQS.Message) {
    this.logger.log(message, 'Processing Error message');
    this.logger.error(error, 'Processing Error Exception');
  }

  @SqsConsumerEventHandler(
    /** name: */ sqsQueueName,
    /** eventName: */ 'timeout_error',
  )
  public onTimeoutError(error: Error, message: AWS.SQS.Message) {
    this.logger.log(message, 'Timeout Error message');
    this.logger.error(error, 'Timeout Error Exception');
  }

[akash-rajput]

Could be related to the bug in underlying package: https://github.com/bbc/sqs-consumer/issues/241

[vhd-luke]

Same issue here

[levanluu]

Can someone tell me how to fix this?

How to restart the instance is not a reasonable way in live environment