Below are my logs
28 Jun 2017 14:15:28,042 [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)
28 Jun 2017 14:15:28,045 [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.tcp.TcpTransport - Stopping transport
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.202:443
28 Jun 2017 14:15:28,046 [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.thread.TaskRunnerFactory - Initialized
TaskRunnerFactory[ActiveMQ Task] using ExecutorService:
java.util.concurrent.ThreadPoolExecutor@30567156[Running, pool size = 0, active
threads = 0, queued tasks = 0, completed tasks = 0]
28 Jun 2017 14:15:28,048 [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.thread.TaskRunnerFactory - Execute[ActiveMQ Task]
runnable: org.apache.activemq.transport.tcp.TcpTransport$1@4f8c8801
28 Jun 2017 14:15:28,048 [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.thread.TaskRunnerFactory - Created thread[ActiveMQ
Task-1]: Thread[ActiveMQ Task-1,5,main]
28 Jun 2017 14:15:28,049 [ActiveMQ Task-1] DEBUG
org.apache.activemq.transport.tcp.TcpTransport - Closing socket
e2bcb15[TLS_RSA_WITH_AES_128_CBC_SHA256:
Socket[addr=il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.202,port=443,localport=64955]]
28 Jun 2017 14:15:28,049 [ActiveMQ Task-1] DEBUG
org.apache.activemq.transport.tcp.TcpTransport - Closed socket
e2bcb15[TLS_RSA_WITH_AES_128_CBC_SHA256:
Socket[addr=il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.202,port=443,localport=64955]]
28 Jun 2017 14:15:28,051 [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.util.ThreadPoolUtils - Forcing shutdown of
ExecutorService: java.util.concurrent.ThreadPoolExecutor@30567156[Running, pool
size = 1, active threads = 0, queued tasks = 0, completed tasks = 1]
28 Jun 2017 14:15:28,051 [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.util.ThreadPoolUtils - Shutdown of ExecutorService:
java.util.concurrent.ThreadPoolExecutor@30567156[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 1] is shutdown: true
and terminated: false.
28 Jun 2017 14:15:28,052 [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]
WARN org.apache.activemq.transport.failover.FailoverTransport - Transport
(ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.202:443)
failed, attempting to automatically reconnect
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)
28 Jun 2017 14:15:28,056 [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.ActiveMQConnection - transport interrupted -
processing required, dispatchers: 1
28 Jun 2017 14:15:28,056 [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.ActiveMQConnection - notified failover transport
(unconnected) of pending interruption processing for:
ID:IVCSW70007257-V-64954-1498630226763-1:1
28 Jun 2017 14:15:28,056 [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.thread.TaskRunnerFactory - Created thread[ActiveMQ
Task-3]: Thread[ActiveMQ Task-3,5,main]
28 Jun 2017 14:15:28,058
[ActiveMQConnection[ID:IVCSW70007257-V-64954-1498630226763-1:1] Scheduler]
DEBUG org.apache.activemq.ActiveMQMessageConsumer -
ID:IVCSW70007257-V-64954-1498630226763-1:1:1:1 clearing unconsumed list (0) on
transport interrupt
28 Jun 2017 14:15:28,058
[ActiveMQConnection[ID:IVCSW70007257-V-64954-1498630226763-1:1] Scheduler]
DEBUG org.apache.activemq.ActiveMQConnection -
transportInterruptionProcessingComplete: 0
for:ID:IVCSW70007257-V-64954-1498630226763-1:1
28 Jun 2017 14:15:28,058
[ActiveMQConnection[ID:IVCSW70007257-V-64954-1498630226763-1:1] Scheduler]
DEBUG org.apache.activemq.ActiveMQConnection - notified failover transport
(unconnected) of interruption completion for:
ID:IVCSW70007257-V-64954-1498630226763-1:1
28 Jun 2017 14:15:28,059 [ActiveMQ Task-3] DEBUG
org.apache.activemq.thread.PooledTaskRunner - Running task iteration 0 -
org.apache.activemq.transport.failover.FailoverTransport$2@7dc9eb54
28 Jun 2017 14:15:28,059 [ActiveMQ Task-3] DEBUG
org.apache.activemq.transport.failover.FailoverTransport - urlList
connectionList:[ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com:443],
from:
[ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com:443]
28 Jun 2017 14:15:28,059 [ActiveMQ Task-3] DEBUG
org.apache.activemq.transport.failover.FailoverTransport - Waiting 10 ms before
attempting connection.
28 Jun 2017 14:15:28,071 [ActiveMQ Task-3] DEBUG
org.apache.activemq.transport.failover.FailoverTransport - Attempting 0th
connect to:
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com:443?wireFormat.maxInactivityDuration=0&useInactivityMonitor=false
28 Jun 2017 14:15:28,168 [ActiveMQ Task-3] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo {
version=10, properties={TcpNoDelayEnabled=true, SizePrefixDisabled=false,
CacheSize=1024, StackTraceEnabled=true, CacheEnabled=true,
TightEncodingEnabled=true, MaxFrameSize=9223372036854775807,
MaxInactivityDuration=0, MaxInactivityDurationInitalDelay=10000},
magic=[A,c,t,i,v,e,M,Q]}
28 Jun 2017 14:15:28,168 [ActiveMQ Transport:
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.103:443]
DEBUG org.apache.activemq.transport.tcp.TcpTransport - TCP consumer thread for
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.103:443
starting
28 Jun 2017 14:15:28,251 [ActiveMQ Transport:
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.103:443]
DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received
WireFormat: WireFormatInfo { version=10, properties={TcpNoDelayEnabled=true,
SizePrefixDisabled=false, CacheSize=1024, StackTraceEnabled=true,
CacheEnabled=true, TightEncodingEnabled=true, MaxFrameSize=104857600,
MaxInactivityDuration=30000, MaxInactivityDurationInitalDelay=10000},
magic=[A,c,t,i,v,e,M,Q]}
28 Jun 2017 14:15:28,252 [ActiveMQ Transport:
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.103:443]
DEBUG org.apache.activemq.transport.WireFormatNegotiator -
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.103:443
before negotiation: OpenWireFormat{version=10, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false,
maxFrameSize=9223372036854775807}
28 Jun 2017 14:15:28,252 [ActiveMQ Transport:
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.103:443]
DEBUG org.apache.activemq.transport.WireFormatNegotiator -
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com/10.165.5.103:443
after negotiation: OpenWireFormat{version=10, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false,
maxFrameSize=104857600}
28 Jun 2017 14:15:28,253 [ActiveMQ Task-3] DEBUG
org.apache.activemq.state.ConnectionStateTracker - conn:
ID:IVCSW70007257-V-64954-1498630226763-1:1
28 Jun 2017 14:15:28,253 [ActiveMQ Task-3] DEBUG
org.apache.activemq.state.ConnectionStateTracker - session:
ID:IVCSW70007257-V-64954-1498630226763-1:1:-1
28 Jun 2017 14:15:28,254 [ActiveMQ Task-3] DEBUG
org.apache.activemq.state.ConnectionStateTracker - consumer:
ID:IVCSW70007257-V-64954-1498630226763-1:1:-1:1
28 Jun 2017 14:15:28,255 [ActiveMQ Task-3] DEBUG
org.apache.activemq.state.ConnectionStateTracker - session:
ID:IVCSW70007257-V-64954-1498630226763-1:1:1
28 Jun 2017 14:15:28,255 [ActiveMQ Task-3] DEBUG
org.apache.activemq.state.ConnectionStateTracker - consumer:
ID:IVCSW70007257-V-64954-1498630226763-1:1:1:1
28 Jun 2017 14:15:28,255 [ActiveMQ Task-3] DEBUG
org.apache.activemq.transport.failover.FailoverTransport - Connection
established
28 Jun 2017 14:15:28,256 [ActiveMQ Task-3] INFO
org.apache.activemq.transport.failover.FailoverTransport - Successfully
reconnected to
ssl://il3-broker-a-il-core-int-06.apps.test-a.0341.o2.we1.csl.cd2.bp.com:443?wireFormat.maxInactivityDuration=0&useInactivityMonitor=false
28 Jun 2017 14:15:28,256 [ActiveMQ Task-3] DEBUG
org.apache.activemq.thread.TaskRunnerFactory - Created thread[ActiveMQ Task-4]:
Thread[ActiveMQ Task-4,5,main]
28
From: jkorab [via ActiveMQ] [mailto:ml+s2283324n4727990...@n4.nabble.com]
Sent: 28 June 2017 18:10
To: Boppana, Lakshmi Prasad (INFOSYS)
Subject: Re: My Subscriber is reconnecting after every 5 mins
Hi,
What do the ActiveMQ logs say at that time?
Jakub
On Wed, Jun 28, 2017 at 7:07 AM, boppana [via ActiveMQ] <[hidden
email]</user/SendEmail.jtp?type=node&node=4727990&i=0>> wrote:
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<http://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<http://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)
________________________________
If you reply to this email, your message will be added to the discussion below:
http://activemq.2283324.n4.nabble.com/My-Subscriber-is-reconnecting-after-every-5-mins-tp4727982.html
To unsubscribe from ActiveMQ - User, click here.
NAML<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml>
________________________________
If you reply to this email, your message will be added to the discussion below:
http://activemq.2283324.n4.nabble.com/My-Subscriber-is-reconnecting-after-every-5-mins-tp4727982p4727990.html
To start a new topic under ActiveMQ - User, email
ml+s2283324n2341805...@n4.nabble.com<mailto:ml+s2283324n2341805...@n4.nabble.com>
To unsubscribe from My Subscriber is reconnecting after every 5 mins, click
here<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=4727982&code=bGFrc2htaS5ib3BwYW5hQHVrLmJwLmNvbXw0NzI3OTgyfDQyNDk4NzEwNw==>.
NAML<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml>
--
View this message in context:
http://activemq.2283324.n4.nabble.com/My-Subscriber-is-reconnecting-after-every-5-mins-tp4727982p4727991.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
