This is how my MessageListener looks like:
*public class Listener implements MessageListener {
public void onMessage(Message message) {
try {
MapMessage map = (MapMessage)message;
Long msgCount = map.getLong("counter");
System.out.println("Message Count Received is " +
msgCount);
} catch (Exception e) {
e.printStackTrace();
}
}
}*
The maxReconnectAttempts=-1 did not work and my Consumer will shutdown if
the connection could not be established within 1 couple of seconds.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Clustering-Issue-tp4655306p4655468.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
