Solved implementing a plugin:

@Component
public class DlqBroker extends BrokerFilter {

        @Override
        public boolean sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
                        Subscription subscription, Throwable poisonCause) {
                ...
        }

conf/activemq.xml
        <plugins>

                ...
                
                <bean id="dlqPlugin"  
xmlns="http://www.springframework.org/schema/beans"; 
                      class="com.rv.activemq.plugin.dlq.DlqPlugin">
                </bean>
        </plugins>



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Reply via email to