Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
<jms:inbound-endpoint connector-ref="Active_MQ" exchange-pattern="one-way" queue="queue1">
<idempotent-redelivery-policy idExpression="#[message.inboundProperties['JMSMessageID']]" />
</jms:inbound-endpoint>
org.mule.transport.jms.redelivery.MessageRedeliveredException: "Message with id "ID:justin-mac.local-50380-1387526838363-3:1:1:1:4" has been redelivered 2 times on endpoint "jms://queue1", which exceeds the maxRedelivery setting of 1 on the connector "Active_MQ". Message payload is of type: ActiveMQTextMessage
at org.mule.transport.jms.redelivery.JmsXRedeliveryHandler.handleRedelivery(JmsXRedeliveryHandler.java:91)
at org.mule.transport.jms.MultiConsumerJmsMessageReceiver$JmsWorker.preProcessMessage(MultiConsumerJmsMessageReceiver.java:428)
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:jms="http://www.mulesoft.org/schema/mule/jms" xmlns="http://www.mulesoft.org/schema/mule/core"
xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
xmlns:test="http://www.mulesoft.org/schema/mule/test" version="EE-3.4.1"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/test http://www.mulesoft.org/schema/mule/test/current/mule-test.xsd
http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd">
<jms:activemq-connector name="Active_MQ" brokerURL="tcp://localhost:61616" maxRedelivery="5" />
<flow name="jmsInFlow">
<jms:inbound-endpoint connector-ref="Active_MQ" exchange-pattern="one-way" queue="queue1">
<idempotent-redelivery-policy idExpression="#[message.inboundProperties['JMSMessageID']]" />
</jms:inbound-endpoint>
<logger level="INFO" message="Received message from JMS" />
<test:component throwException="true" exceptionToThrow="java.lang.Exception" />
<rollback-exception-strategy maxRedeliveryAttempts="3">
<logger message="retrying request" level="INFO"/>
<on-redelivery-attempts-exceeded>
<logger message="REDELIVERY EXHAUSTED" level="ERROR"/>
</on-redelivery-attempts-exceeded>
</rollback-exception-strategy>
</flow>
</mule>
org.mule.api.exception.MessageRedeliveredException: Maximum redelivery attempts reached. Message payload is of type: String
at org.mule.processor.IdempotentRedeliveryPolicy.process(IdempotentRedeliveryPolicy.java:198)
at org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor.execute(ExceptionToMessagingExceptionExecutionInterceptor.java:27)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.