Skip to content

Instantly share code, notes, and snippets.

@mzimecki
Created May 27, 2017 18:45
Show Gist options
  • Save mzimecki/5aa3e3e00d39ecc3abbb88026b8e9a47 to your computer and use it in GitHub Desktop.
Save mzimecki/5aa3e3e00d39ecc3abbb88026b8e9a47 to your computer and use it in GitHub Desktop.
Dead Letter Queue
@Component
public class QueueReaderRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("jms:deadLetterQueue")
.routeId(ServiceConstants.QUEUE_READER_ROUTE_ID)
.process(new RedeliveryProcessor())
.to(ExchangePattern.InOnly, "jms:destinationQueue")
.end();
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment