activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "anton.mithun" <mithunantonru...@gmail.com>
Subject ActiveMQ Artemis Reconnection/Disconnect notification.
Date Fri, 22 Jul 2016 09:08:53 GMT
Hi,

Artemis connection setup is done during the initial bean loading. 

            connectionFactory = new
ActiveMQConnectionFactory(connectionUrl);
            connectionFactory.setReconnectAttempts(reconnectAttempts); 
            connection = connectionFactory.createConnection(username,
password);
            connection.start();
            session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
            producer = session.createProducer(null);
            connection.setExceptionListener(new FailoverListener());


private class FailoverListener implements ExceptionListener {..}

And after that I am sending messages in a irregular intervals using this
producer.

public boolean publish(Serializable message, String queueName) {
        boolean success = true;
        try {
            Queue queue = session.createQueue(queueName);
            ObjectMessage objectMessage = session.createObjectMessage();
            objectMessage.setObject(message);
            producer.send(queue, objectMessage);
            LOGGER.debug("Sent Message : " +
objectMessage.getObject().toString() + " Queue Name : " +
queue.getQueueName());
        } catch (JMSException e) {
            LOGGER.error(e.getMessage(), e);
            success = false;
        }
        return success;
    }

 The ExceptionListener will get code from the exception like   FAILOVER and
DISCONNECT. 
As I need automatic reattachment of the session I have given the option 
connectionFactory.setReconnectAttempts(reconnectAttempts); 
which will look for FAILOVER.

My problem is that I want to get notified when the server gets disconnected
as well as FAILOVER. that is to get DISCONNECT and FAILOVER . so that I can
stop publishing.
Since I have given reconnectAttempts = -1 , DISCONNECT will not be send
until reattempts are done, which are infinite attempts ! 
How can I get notified for both these events?

Thanks.




--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Artemis-Reconnection-Disconnect-notification-tp4714293.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message