Stack Overflow
Stack Overflow

Questions tagged [dead-letter]

250 questions
60
votes
8 answers

RabbitMQ dead letter exchange never getting messages

I'm trying to setup my first RabbitMQ dead letter exchange, here are the steps I'm using through the web admin interface: Create new DIRECT exchange with the name "dead.letter.test" Create new queue "dead.letter.queue" Bind "dead.letter.queue" to…
jhilden
  • 12,207
  • 5
  • 53
  • 76
23
votes
1 answer

Dead letter queue (DLQ) for Kafka with spring-kafka

What is the best way to implement Dead letter queue (DLQ) concept in Spring Boot 2.0 application using spring-kafka 2.1.x to have all messages that were failed to be processed by @KafkaListener method of some bean sent to some predefined Kafka DLQ…
Eugene Khyst
  • 9,236
  • 7
  • 38
  • 65
16
votes
1 answer

Dealing with dead letters in RabbitMQ

TL;DR: I need to "replay" dead letter messages back into their original queues once I've fixed the consumer code that was originally causing the messages to be rejected. I have configured the Dead Letter Exchange (DLX) for RabbitMQ and am…
Dan
  • 445
  • 1
  • 6
  • 15
14
votes
1 answer

How to view akka dead letters

I've created an Actor that performs some basic operations and appears to be working correctly - however I'm seeing the following show up in my logs regularly [INFO] [05/28/2014 14:24:00.673] [application-akka.actor.default-dispatcher-5]…
James Davies
  • 9,602
  • 5
  • 38
  • 42
11
votes
2 answers

AWS - What is the difference between setting a Dead Letter Queue on an SNS Subscription or on a Lambda function?

What is the difference between setting a Dead Letter Queue on an SNS Topic or on a Lambda function? I was wondering, because if you set the DLQ on the SNS subscription, then that subscription message will fail over to DLQ when the Lambda (the…
Blundell
  • 75,855
  • 30
  • 208
  • 233
10
votes
1 answer

How to set per-message expiration (TTL) in Celery?

It is possible to publish messages into a RabbitMQ queue with an expiration TTL: such messages will expire once the TTL is done and (if a dead-letter queue is setup,) removed to the dead-letter queue. But is it possible to specify such per-message…
FuzzyAmi
  • 7,543
  • 6
  • 45
  • 79
10
votes
3 answers

How do I delete a DeadLetter message on an Azure Service Bus Topic

I'm writing a piece of code which will allow us to: View a list of all dead letter messages that exist within an Azure Service Bus Topic (Peek) Fix and send them back to the Topic Delete them from the dead letter queue upon resending. I have no…
Luke Merrett
  • 5,724
  • 8
  • 38
  • 70
8
votes
2 answers

How to route dead letter messages back to the original topic?

I have a Google Cloud Pub/Sub subscription that is using a dead-letter topic. I recently had an outage that was preventing a number of messages from being processed & they ended up in the dead-letter topic. The outage was resolved and I'd like to…
Mark McDonald
  • 7,571
  • 6
  • 46
  • 53
8
votes
4 answers

How to move a service bus messge to deadletter in service bus queue trigger function

How can we move a service bus queue message to the dead letter through service bus queue trigger function
jaas
  • 131
  • 1
  • 5
8
votes
1 answer

DLQ on Failed Task in Step Function

In case of Failed Task in step function, after trying with retry strategy, is there a way I can put these Failed tasks in some DLQ or something like that so that someone can monitor these messages later and redrive them after fixing the issue?
hatellla
  • 4,796
  • 8
  • 49
  • 101
8
votes
1 answer

AWS SQS Boto3 sending messages to dead letter manually

So I am building a small application that uses SQS. I have a simple handler process that determines if a given message is considered processed, marked for retry (to be re-queued) or is not able to be processed (should be sent to dead…
Mike
  • 632
  • 7
  • 22
7
votes
2 answers

Is there any way to explicitly send event message to dead letter queue from inside AWS lambda function on certain condition?

I'm trying to send s3event message to rabbitmq by invoking AWS lambda function. I have configured SQS as my dead letter queue(DLQ). I know the message is sent to DLQ when there failure in invocation of lambda or situations like timeouts or resource…
Vinod Singh
  • 145
  • 1
  • 3
  • 8
7
votes
3 answers

Dead-lettering dead-lettered messages in RabbitMQ

Here's what we have here: Topic Exchange DLE, which is intended to be a Dead-Letter Exchange Topic Exchange E, which is the "main" Exchange Several Queues (EQ1, ..., EQn) bound to E (and initialized with x-dead-letter-exchange = DLE), each with own…
Anton Gogolev
  • 113,561
  • 39
  • 200
  • 288
7
votes
2 answers

RabbitMQ, dead letters exchanges -> Can't route message to the default exchange?

With the RabbitMQ Admin (v3), I tried to create a queue that will send dead letter messages to the default exchange, with a routing key "MyErrorRoutingKey" on which is binded an error queue. So in the administration interface, I left the "dead…
Sebastien Lorber
  • 89,644
  • 67
  • 288
  • 419
7
votes
1 answer

Dead letter exchange RabbitMQ dropping messages

I'm trying to implement a dlx queue in RabbitMQ. The scenario is quite easy I have 2 queues: 1) alive 2) dead (x-dead-letter-exchange: "immediate", x-message-ttl: 5000) and an exchange "immediate" that is bound to 1) alive I tried to run this…
Fabrizio Sestito
  • 93
  • 1
  • 4
1
2 3
…
16 17