This is what I am doing:

public class ActiveMQAuthConnectionFactory extends 
     org.apache.activemq.ActiveMQConnectionFactory
{
private static class AMQExceptionListener implements ExceptionListener
    {
        @Override
        public void onException(JMSException exception)
        {
            LOG.info("XXX Exception is " + exception);
        }
    }

public ActiveMQAuthConnectionFactory()
{
        super();
        super.setExceptionListener(new AMQExceptionListener());
}
}

I am then using this ActiveMQAuthConnectionFactory wrapped in a
PooledConnectionFactory which is passed to JmsTemplate.

    <bean id="connectionFactory"
class="common.jms.ActiveMQAuthConnectionFactory">
        <property name="brokerURL"
value="failover://(tcp://test1.hyd:61616)" />
    </bean>

    
    <bean id="jmsConnectionFactory"
        class="org.apache.activemq.pool.PooledConnectionFactory"
        destroy-method="stop">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="maxConnections" value="5" /> 
    </bean>

Could somebody explain what I am doing wrong here?




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ExceptionListener-not-getting-fired-on-the-client-side-when-using-JmsTemplate-tp4673285p4673286.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to