Hi Team,
Iam as a subscriber using following url for connecting my AMQ broker
url = "failover://(ssl://"
                                + 
SubParams.getPropertyVal(SubParams.SUBSCRIBER_EMS_SERVER)
                                + ":"
                                + 
SubParams.getPropertyVal(SubParams.SUBSCRIBER_EMS_PORT)
                                + ")?jms.useCompression=true&maxReconnectDelay="
                                + SubParams
                                                
.getIntVal(SubParams.SUBSCRIBER_EMS_CONNECT_ATTEMPT_DELAY)
                                + "&timeout="
                                + SubParams
                                                
.getIntVal(SubParams.SUBSCRIBER_EMS_CONNECT_ATTEMPT_TIMEOUT)
                                + "&maxReconnectAttempts="
                                + SubParams
                                                
.getIntVal(SubParams.SUBSCRIBER_EMS_CONNECT_ATTEMPT_COUNT)
                                +
"&nested.useInactivityMonitor=false&nested.wireFormat.maxInactivityDuration=0";

If publisher is not publishing any messages then after 5 mins my subscriber
is going down and again as I mentioned failover its able to successfully
reconnect.But why its always going down after every 5 mins and how can I
avoid this?
Am getting below error when subscriber is going down

[ActiveMQ Transport:
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.202:443]
DEBUG org.apache.activemq.transport.failover.FailoverTransport -
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com:443?wireFormat.maxInactivityDuration=0&useInactivityMonitor=false
handleTransportFailure: java.io.EOFException
java.io.EOFException
        at java.io.DataInputStream.readInt(DataInputStream.java:392)
        at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258)
        at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)
        at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
        at java.lang.Thread.run(Thread.java:745)




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/My-Subscriber-is-reconnecting-after-every-5-mins-tp4727982.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to