debmalya / activemqstaleconnectionhandler

How to handle reconnection after inactivity IO exception from ActiveMQ

• 👋 Hi, I’m @jash
• 👀 I’m interested in Java, Python, Golang, Rust, Algorithm
• 🌱 I’m currently learning Algorithm
• 💞️ I’m looking to collaborate on ...
• 📫 How to reach me ...

activemqstaleconnectionhandler's Issues

One ActiveMQ connection is down from the beginning, another one is running.

java.lang.NullPointerException
at com.example.JMSLoadBalancerSink.reconnect(JMSLoadBalancerSink.java:337)
at com.example.JMSLoadBalancerSink.access$1(JMSLoadBalancerSink.java:324)
at com.example.JMSLoadBalancerSink$Recoverer.run(JMSLoadBalancerSink.java:470)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)

One ActiveMQ connection is down, another one is up. Playing 1000 message. 500 messages received ,

Only 500 message are there in second activeMQ queue.

Testing with two activeMQ connections, first connection is down and second connection is active.

WARNING: Number of times failed to connect: 1
java.lang.IndexOutOfBoundsException: Index: 1, Size: 1
at java.util.ArrayList.rangeCheck(ArrayList.java:653)
at java.util.ArrayList.get(ArrayList.java:429)
at com.example.JMSLoadBalancerSink.connect(JMSLoadBalancerSink.java:158)
at com.example.JMSLoadBalancerSink.initialize(JMSLoadBalancerSink.java:105)
at com.example.JMSLoadBalancerSinkTest.setup(JMSLoadBalancerSinkTest.java:16)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:24)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:86)
at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)