Tags


public class YourListeners implements MessageListener, 
				ExceptionListener, 
                                TransportListener 
{
:
:

Need to get ActiveMQConnection first, then 

- yourconsumer.setMessageListener(this);
- activeMqConnection.setExceptionListener(this);
- activeMqConnection.addTransportListener(this);

Advertisements