Uploaded image for project: 'FUSE Mediation Router'
  1. FUSE Mediation Router
  2. MR-408

@Consume from AMQ queue on pojo during shutdown issue

    XMLWordPrintable

Details

    • Task
    • Resolution: Done
    • Major
    • 2.6.0-fuse-01-09
    • 2.6.0-fuse-00-00
    • None
    • None

    Description

      apache-camel-2.6.0-fuse-00-00/examples/camel-example-pojo-messaging$ mvn camel:run

      When running this example and you stop using ctrl + c you will see

      ^C[                      Thread-1] MainSupport$HangupInterceptor  INFO  Received hang up - stopping the main instance.
      [                      Thread-1] MainSupport                    INFO  Apache Camel 2.6.0-fuse-00-00 stopping
      [         ActiveMQ ShutdownHook] BrokerService                  INFO  ActiveMQ Message Broker (localhost, ID:davsclaus.local-61508-1296139626231-0:1) is shutting down
      [                      Thread-1] BrokerService                  INFO  ActiveMQ Message Broker (localhost, ID:davsclaus.local-61508-1296139626231-0:1) is shutting down
      [                      Thread-1] TransportConnector             INFO  Connector vm://localhost Stopped
      [         ActiveMQ ShutdownHook] TransportConnector             INFO  Connector vm://localhost Stopped
      [         ActiveMQ ShutdownHook] BrokerService                  INFO  ActiveMQ JMS Message Broker (localhost, ID:davsclaus.local-61508-1296139626231-0:1) stopped
      [                      Thread-1] BrokerService                  INFO  ActiveMQ JMS Message Broker (localhost, ID:davsclaus.local-61508-1296139626231-0:1) stopped
      [                      Thread-1] SpringCamelContext             INFO  Apache Camel 2.6.0-fuse-00-00 (CamelContext:camel-1) is shutting down
      [                      Thread-1] DefaultShutdownStrategy        INFO  Starting to graceful shutdown 0 routes (timeout 300 seconds)
      [                      Thread-1] DefaultShutdownStrategy        INFO  Graceful shutdown of 0 routes completed in 0 seconds
      [aultMessageListenerContainer-1] efaultMessageListenerContainer WARN  Setup of JMS message listener invoker failed for destination 'personnel.records' - trying to recover. Cause: The Consumer is closed
      [aultMessageListenerContainer-1] efaultMessageListenerContainer WARN  Could not refresh JMS Connection for destination 'personnel.records' - retrying in 5000 ms. Cause: null
      [                      Thread-1] DefaultInflightRepository      INFO  Shutting down with no inflight exchanges.
      [                      Thread-1] SpringCamelContext             INFO  Uptime: 43.389 seconds
      [                      Thread-1] SpringCamelContext             INFO  Apache Camel 2.6.0-fuse-00-00 (CamelContext: camel-1) is shutdown in 20.011 seconds
      

      The @Consume should be able to detect the shutdown and cause the JMS listener to not try to recover.

      Also in this example we can maybe fix it by shutting down AMQ last.

      Attachments

        Activity

          People

            cibsen@redhat.com Claus Ibsen
            cibsen@redhat.com Claus Ibsen
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: