SimpleMessageListenerContainer failed to reconnect on ems broker failover










1















I have 2 jms listener applications one application uses DefaultMessageListenerContainerand other application uses SimpleMessageListenerContainer



The application with DefaultMessageListenerContainer was able to reconnect on EMS broker failover, here is the log



Setup of JMS message listener invoker failed for destination 'SOME.TOPIC.T' - trying to recover. Cause: Connection is closed
Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=0, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286
Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=1, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286


The application with SimpleMessageListenerContainer was not able to reconnect on EMS broker failover, here is the log



[TIBCO EMS TCPLink Reader (Server-109365)] INFO org.springframework.jms.listener.SimpleMessageListenerContainer - Trying to recover from JMS Connection exception: javax.jms.JMSException: Connection has been terminated
[TIBCO EMS TCPLink Reader (Server-109366)] ERROR org.springframework.jms.listener.SimpleMessageListenerContainer - Encountered non-recoverable JMSException
javax.jms.JMSException: Connection has been terminated
at com.tibco.tibjms.Tibjmsx.buildException(Tibjmsx.java:659) ~[tibjms-8.3.0.jar!/:?]
at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2118) [tibjms-8.3.0.jar!/:?]
at com.tibco.tibjms.TibjmsConnection._onDisconnected(TibjmsConnection.java:2487) [tibjms-8.3.0.jar!/:?]
at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventDisconnected(TibjmsConnection.java:367) [tibjms-8.3.0.jar!/:?]
at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:328) [tibjms-8.3.0.jar!/:?]
at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259) [tibjms-8.3.0.jar!/:?]


Both are connected to same broker instance, how to make the SimpleMessageListenerContainer listener to reconnect on JMS Exceptions?










share|improve this question


























    1















    I have 2 jms listener applications one application uses DefaultMessageListenerContainerand other application uses SimpleMessageListenerContainer



    The application with DefaultMessageListenerContainer was able to reconnect on EMS broker failover, here is the log



    Setup of JMS message listener invoker failed for destination 'SOME.TOPIC.T' - trying to recover. Cause: Connection is closed
    Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=0, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286
    Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=1, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286


    The application with SimpleMessageListenerContainer was not able to reconnect on EMS broker failover, here is the log



    [TIBCO EMS TCPLink Reader (Server-109365)] INFO org.springframework.jms.listener.SimpleMessageListenerContainer - Trying to recover from JMS Connection exception: javax.jms.JMSException: Connection has been terminated
    [TIBCO EMS TCPLink Reader (Server-109366)] ERROR org.springframework.jms.listener.SimpleMessageListenerContainer - Encountered non-recoverable JMSException
    javax.jms.JMSException: Connection has been terminated
    at com.tibco.tibjms.Tibjmsx.buildException(Tibjmsx.java:659) ~[tibjms-8.3.0.jar!/:?]
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2118) [tibjms-8.3.0.jar!/:?]
    at com.tibco.tibjms.TibjmsConnection._onDisconnected(TibjmsConnection.java:2487) [tibjms-8.3.0.jar!/:?]
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventDisconnected(TibjmsConnection.java:367) [tibjms-8.3.0.jar!/:?]
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:328) [tibjms-8.3.0.jar!/:?]
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259) [tibjms-8.3.0.jar!/:?]


    Both are connected to same broker instance, how to make the SimpleMessageListenerContainer listener to reconnect on JMS Exceptions?










    share|improve this question
























      1












      1








      1








      I have 2 jms listener applications one application uses DefaultMessageListenerContainerand other application uses SimpleMessageListenerContainer



      The application with DefaultMessageListenerContainer was able to reconnect on EMS broker failover, here is the log



      Setup of JMS message listener invoker failed for destination 'SOME.TOPIC.T' - trying to recover. Cause: Connection is closed
      Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=0, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286
      Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=1, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286


      The application with SimpleMessageListenerContainer was not able to reconnect on EMS broker failover, here is the log



      [TIBCO EMS TCPLink Reader (Server-109365)] INFO org.springframework.jms.listener.SimpleMessageListenerContainer - Trying to recover from JMS Connection exception: javax.jms.JMSException: Connection has been terminated
      [TIBCO EMS TCPLink Reader (Server-109366)] ERROR org.springframework.jms.listener.SimpleMessageListenerContainer - Encountered non-recoverable JMSException
      javax.jms.JMSException: Connection has been terminated
      at com.tibco.tibjms.Tibjmsx.buildException(Tibjmsx.java:659) ~[tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2118) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsConnection._onDisconnected(TibjmsConnection.java:2487) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventDisconnected(TibjmsConnection.java:367) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:328) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259) [tibjms-8.3.0.jar!/:?]


      Both are connected to same broker instance, how to make the SimpleMessageListenerContainer listener to reconnect on JMS Exceptions?










      share|improve this question














      I have 2 jms listener applications one application uses DefaultMessageListenerContainerand other application uses SimpleMessageListenerContainer



      The application with DefaultMessageListenerContainer was able to reconnect on EMS broker failover, here is the log



      Setup of JMS message listener invoker failed for destination 'SOME.TOPIC.T' - trying to recover. Cause: Connection is closed
      Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=0, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286
      Could not refresh JMS Connection for destination 'SOME.TOPIC.T' - retrying using FixedBackOffinterval=5000, currentAttempts=1, maxAttempts=unlimited. Cause: Failed to connect to any server at: tcp://localhost:8285,tcp://localhost:8286


      The application with SimpleMessageListenerContainer was not able to reconnect on EMS broker failover, here is the log



      [TIBCO EMS TCPLink Reader (Server-109365)] INFO org.springframework.jms.listener.SimpleMessageListenerContainer - Trying to recover from JMS Connection exception: javax.jms.JMSException: Connection has been terminated
      [TIBCO EMS TCPLink Reader (Server-109366)] ERROR org.springframework.jms.listener.SimpleMessageListenerContainer - Encountered non-recoverable JMSException
      javax.jms.JMSException: Connection has been terminated
      at com.tibco.tibjms.Tibjmsx.buildException(Tibjmsx.java:659) ~[tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2118) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsConnection._onDisconnected(TibjmsConnection.java:2487) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventDisconnected(TibjmsConnection.java:367) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:328) [tibjms-8.3.0.jar!/:?]
      at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259) [tibjms-8.3.0.jar!/:?]


      Both are connected to same broker instance, how to make the SimpleMessageListenerContainer listener to reconnect on JMS Exceptions?







      jms spring-jms spring-integration-dsl






      share|improve this question













      share|improve this question











      share|improve this question




      share|improve this question










      asked Nov 13 '18 at 23:32









      nagendranagendra

      233519




      233519






















          1 Answer
          1






          active

          oldest

          votes


















          1














          The simple container is ... er ... Simple.



          It makes only one attempt to recover the connection.



          The default container is more sophisticated and configured with a BackOff (default every 5 seconds for infinite attempts).



          Use a default container if you need that sophistication, but it needs to be transactional to avoid the possibility of message loss - see the javadocs.






          share|improve this answer






















            Your Answer






            StackExchange.ifUsing("editor", function ()
            StackExchange.using("externalEditor", function ()
            StackExchange.using("snippets", function ()
            StackExchange.snippets.init();
            );
            );
            , "code-snippets");

            StackExchange.ready(function()
            var channelOptions =
            tags: "".split(" "),
            id: "1"
            ;
            initTagRenderer("".split(" "), "".split(" "), channelOptions);

            StackExchange.using("externalEditor", function()
            // Have to fire editor after snippets, if snippets enabled
            if (StackExchange.settings.snippets.snippetsEnabled)
            StackExchange.using("snippets", function()
            createEditor();
            );

            else
            createEditor();

            );

            function createEditor()
            StackExchange.prepareEditor(
            heartbeatType: 'answer',
            autoActivateHeartbeat: false,
            convertImagesToLinks: true,
            noModals: true,
            showLowRepImageUploadWarning: true,
            reputationToPostImages: 10,
            bindNavPrevention: true,
            postfix: "",
            imageUploader:
            brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
            contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
            allowUrls: true
            ,
            onDemand: true,
            discardSelector: ".discard-answer"
            ,immediatelyShowMarkdownHelp:true
            );



            );













            draft saved

            draft discarded


















            StackExchange.ready(
            function ()
            StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53291040%2fsimplemessagelistenercontainer-failed-to-reconnect-on-ems-broker-failover%23new-answer', 'question_page');

            );

            Post as a guest















            Required, but never shown

























            1 Answer
            1






            active

            oldest

            votes








            1 Answer
            1






            active

            oldest

            votes









            active

            oldest

            votes






            active

            oldest

            votes









            1














            The simple container is ... er ... Simple.



            It makes only one attempt to recover the connection.



            The default container is more sophisticated and configured with a BackOff (default every 5 seconds for infinite attempts).



            Use a default container if you need that sophistication, but it needs to be transactional to avoid the possibility of message loss - see the javadocs.






            share|improve this answer



























              1














              The simple container is ... er ... Simple.



              It makes only one attempt to recover the connection.



              The default container is more sophisticated and configured with a BackOff (default every 5 seconds for infinite attempts).



              Use a default container if you need that sophistication, but it needs to be transactional to avoid the possibility of message loss - see the javadocs.






              share|improve this answer

























                1












                1








                1







                The simple container is ... er ... Simple.



                It makes only one attempt to recover the connection.



                The default container is more sophisticated and configured with a BackOff (default every 5 seconds for infinite attempts).



                Use a default container if you need that sophistication, but it needs to be transactional to avoid the possibility of message loss - see the javadocs.






                share|improve this answer













                The simple container is ... er ... Simple.



                It makes only one attempt to recover the connection.



                The default container is more sophisticated and configured with a BackOff (default every 5 seconds for infinite attempts).



                Use a default container if you need that sophistication, but it needs to be transactional to avoid the possibility of message loss - see the javadocs.







                share|improve this answer












                share|improve this answer



                share|improve this answer










                answered Nov 14 '18 at 1:31









                Gary RussellGary Russell

                82.6k74773




                82.6k74773





























                    draft saved

                    draft discarded
















































                    Thanks for contributing an answer to Stack Overflow!


                    • Please be sure to answer the question. Provide details and share your research!

                    But avoid


                    • Asking for help, clarification, or responding to other answers.

                    • Making statements based on opinion; back them up with references or personal experience.

                    To learn more, see our tips on writing great answers.




                    draft saved


                    draft discarded














                    StackExchange.ready(
                    function ()
                    StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53291040%2fsimplemessagelistenercontainer-failed-to-reconnect-on-ems-broker-failover%23new-answer', 'question_page');

                    );

                    Post as a guest















                    Required, but never shown





















































                    Required, but never shown














                    Required, but never shown












                    Required, but never shown







                    Required, but never shown

































                    Required, but never shown














                    Required, but never shown












                    Required, but never shown







                    Required, but never shown







                    Popular posts from this blog

                    Use pre created SQLite database for Android project in kotlin

                    Darth Vader #20

                    Ondo