We are currently establishing a broker to broker connection to a remote
RabbitMQ server using the STOMP and MQTT protocols. This works fine with
AMPQ however with STOMP and MQTT, if the remote RabbitMQ server is down and
we bounce the AMQ server it either does not start up or fails very shortly
afterwards.
Is this expected or is there any additional configuration we require?
We are using the following:
AMQ - 5.10.0
camel - 2.17
RabbitMQ - 3.5.0
This runs on:
Linux 6.4
In terms of CAMEL route configuration we have the following:
<route>
<from uri="activemq:topic://myTopic"/>
<to
uri="mqtt:my?host=ssl://xxxxxx:1884&qualityOfService=AtLeastOnce&publishTopicName=logs&userName=xxxxxxxxxx&password=xxxxxxxxx"/>
</route>
<route>
<from
uri="activemq:topic://myTopic?clientId=3&durableSubscriptionName=stompbroker"/>
<to uri="stomp:queue:logs?brokerURL=ssl://<<ip
address>>:<<port>>&login=<login>&passcode=<passcode>&
host=<<Rabbit MQ Vhost name>> "/>
</route>
In terms of logging we have the following for STOMP:
[DEBUG] 2016-04-08 11:52:41,368 org.apache.camel.impl.DefaultComponent
createEndpoint -Creating endpoint
uri=[activemq://topic://myTopic?clientId=3&durableSubscriptionName=stompbroker],
path=[topic://myTopic]
[DEBUG] 2016-04-08 11:52:41,384 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: clientId on bean:
org.apache.activemq.camel.component.ActiveMQConfiguration@4bd6d546 with
value: 3
[DEBUG] 2016-04-08 11:52:41,387 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: durableSubscriptionName on bean:
org.apache.activemq.camel.component.ActiveMQConfiguration@4bd6d546 with
value: stompbroker
[DEBUG] 2016-04-08 11:52:41,396 org.apache.camel.spring.SpringCamelContext
getEndpoint
-activemq://topic://myTopic?clientId=3&durableSubscriptionName=stompbroker
converted to endpoint:
Endpoint[activemq://topic://myTopic?clientId=3&durableSubscriptionName=stompbroker]
by component: org.apache.activemq.camel.component.ActiveMQComponent@cdf3d70
[DEBUG] 2016-04-08 11:52:41,451
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer
-Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="activemq://topic://myTopic\?clientId=3&durableSubscriptionName=stompbroker"
[DEBUG] 2016-04-08 11:52:41,459 org.apache.camel.spring.SpringCamelContext
getComponent -Using ComponentResolver:
org.apache.camel.impl.DefaultComponentResolver@7a0598d5 to resolve component
with name: stomp
[DEBUG] 2016-04-08 11:52:41,462
org.apache.camel.impl.DefaultComponentResolver resolveComponent -Found
component: stomp in registry: null
[DEBUG] 2016-04-08 11:52:41,466
org.apache.camel.impl.DefaultComponentResolver resolveComponent -Found
component: stomp via type: org.apache.camel.component.stomp.StompComponent
via: META-INF/services/org/apache/camel/component/stomp
[DEBUG] 2016-04-08 11:52:41,473
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer
-Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="stomp"
[DEBUG] 2016-04-08 11:52:41,478 org.apache.camel.impl.DefaultComponent
createEndpoint -Creating endpoint
uri=[stomp://queue:logs?brokerURL=ssl%3A%2F%2F<IPAddr>%3A61613&host=mytest&login=<login>&passcode=<passcode>],
path=[queue:logs]
[DEBUG] 2016-04-08 11:52:41,485 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: brokerURL on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:
ssl://<IPAddr>:61613
[DEBUG] 2016-04-08 11:52:41,493 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: host on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:
mytest
[DEBUG] 2016-04-08 11:52:41,496 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: login on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:
<login>
[DEBUG] 2016-04-08 11:52:41,504 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: passcode on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:
<passcode>
[DEBUG] 2016-04-08 11:52:41,516 org.apache.camel.spring.SpringCamelContext
getEndpoint
-stomp://queue:logs?brokerURL=ssl%3A%2F%2F<IPAddr>%3A61613&host=mytest&login=<login>&passcode=<passcode>
converted to endpoint:
Endpoint[stomp://queue:logs?brokerURL=ssl%3A%2F%2F<IPAddr>%3A61613&host=mytest&login=<login>&passcode=<passcode>]
by component: org.apache.camel.component.stomp.StompComponent@27d74a21
[DEBUG] 2016-04-08 11:52:41,521
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer
-Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="stomp://queue:logs\?brokerURL=ssl%3A%2F%2F<IPAddr>%3A61613&host=mytest&login=<login>&passcode=<passcode>"
[INFO] 2016-04-08 11:52:41,641 org.apache.camel.spring.SpringCamelContext
doStop -Apache Camel 2.17.0 (CamelContext: camel-1) is shutting down
[DEBUG] 2016-04-08 11:52:41,645
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager doStop -Shutting
down with no inflight threads.
[DEBUG] 2016-04-08 11:52:41,648
org.apache.camel.support.TimerListenerManager removeTimerListener -Removed
TimerListener:
org.apache.camel.management.mbean.ManagedCamelContext@2b2b1e58
[DEBUG] 2016-04-08 11:52:41,652
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=context,name="camel-1"
[DEBUG] 2016-04-08 11:52:41,655
org.apache.camel.impl.DefaultInflightRepository doStop -Shutting down with
no inflight exchanges.
[DEBUG] 2016-04-08 11:52:41,658
org.apache.camel.impl.SharedPollingConsumerServicePool doStop -Stopping
service pool:
org.apache.camel.impl.SharedPollingConsumerServicePool@202533b1
[DEBUG] 2016-04-08 11:52:41,661
org.apache.camel.impl.SharedProducerServicePool doStop -Stopping service
pool: org.apache.camel.impl.SharedProducerServicePool@796e624f
[DEBUG] 2016-04-08 11:52:41,665 org.apache.camel.util.EventHelper
doNotifyEvent -Ignoring notifying event Stopped CamelContext: camel-1. The
EventNotifier has not been started yet:
org.apache.camel.impl.DefaultRuntimeEndpointRegistry@3ce41206
[DEBUG] 2016-04-08 11:52:41,668
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultTypeConverter
[DEBUG] 2016-04-08 11:52:41,670
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="stomp"
[DEBUG] 2016-04-08 11:52:41,673
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultRuntimeEndpointRegistry
[DEBUG] 2016-04-08 11:52:41,676
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultRestRegistry
[DEBUG] 2016-04-08 11:52:41,679
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="activemq"
[DEBUG] 2016-04-08 11:52:41,681
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultAsyncProcessorAwaitManager
[DEBUG] 2016-04-08 11:52:41,684
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultEndpointRegistry
[DEBUG] 2016-04-08 11:52:41,687
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="activemq://topic://myTopic\?clientId=3&durableSubscriptionName=stompbroker"
[DEBUG] 2016-04-08 11:52:41,689
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="spring-event"
[DEBUG] 2016-04-08 11:52:41,692
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="stomp://queue:logs\?brokerURL=ssl%3A%2F%2F<IPAddr>%3A61613&host=mytest&login=<login>&passcode=<passcode>"
[DEBUG] 2016-04-08 11:52:41,695
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultInflightRepository
[DEBUG] 2016-04-08 11:52:41,697
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultShutdownStrategy
[DEBUG] 2016-04-08 11:52:41,700
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=services,name=DefaultExecutorServiceManager
[DEBUG] 2016-04-08 11:52:41,703 org.apache.camel.util.IntrospectionSupport
stop -Clearing cache[size=42, hits=33, misses=42, evicted=0]
[INFO] 2016-04-08 11:52:41,707 org.apache.camel.spring.SpringCamelContext
doStop -Apache Camel 2.17.0 (CamelContext: camel-1) uptime 0.692 seconds
[INFO] 2016-04-08 11:52:41,709 org.apache.camel.spring.SpringCamelContext
doStop -Apache Camel 2.17.0 (CamelContext: camel-1) is shutdown in 0.065
seconds
[INFO] 2016-04-08 11:52:41,723 org.apache.activemq.broker.BrokerService stop
-Apache ActiveMQ 5.10.0 (myBROKER, ID:<ID>) is shutting down
[DEBUG] 2016-04-08 11:52:41,725 org.apache.activemq.broker.BrokerService
removeShutdownHook -Caught exception, must be shutting down. This exception
is ignored.
java.lang.IllegalStateException: Shutdown in progress
at
java.lang.ApplicationShutdownHooks.remove(ApplicationShutdownHooks.java:82)
at java.lang.Runtime.removeShutdownHook(Runtime.java:239)
at
org.apache.activemq.broker.BrokerService.removeShutdownHook(BrokerService.java:2358)
at org.apache.activemq.broker.BrokerService.stop(BrokerService.java:743)
at
org.apache.activemq.xbean.XBeanBrokerService.stop(XBeanBrokerService.java:122)
at
org.apache.activemq.broker.BrokerService.containerShutdown(BrokerService.java:2381)
at
org.apache.activemq.broker.BrokerService$6.run(BrokerService.java:2348)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQ-fails-if-remote-broker-is-not-started-via-Camel-using-STOMP-and-MQTT-tp4710709.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
