java ee - ActiveMQ forwarding from local broker to a remote broker [with unstable connection] -



java ee - ActiveMQ forwarding from local broker to a remote broker [with unstable connection] -

i have next problem: have several sites local activemq broker forwards remote broker (in datacenter). connection unstable, , goes downwards several times month few minutes or hours @ time.

messages hence need wait on local broker if remote broker not accessible @ moment.

i have next activemq configuration:

<networkconnectors> <networkconnector uri="static://(tcp://my-remote-broker:61616)" name="myremotebroker" dynamiconly="false" conduitsubscriptions="true" decreasenetworkconsumerpriority="false"> <!-- exclude destinations default --> <excludeddestinations> <queue physicalname=">" /> <topic physicalname=">" /> </excludeddestinations> <!-- forwards these our connection --> <staticallyincludeddestinations> <topic physicalname="myspecialtopic"/> </staticallyincludeddestinations> </networkconnector> </networkconnectors>

this forwards messages local broker (on topic myspecialtopic), remote broker. works when connection stable.

however, tried temporarily disabling net connection, local broker lost connection remote broker. @ point sent new message, enqueued on local broker, never arrived on remote broker, even after local broker re-connected!

is there in activemq configuration missing?

thanks!

you using topic, nail or miss. means sending message while connection downwards lost, standard behaviour topic ( subscribers subscribed @ time of send of message receive message). (http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html)

you should utilize queue if want remote consumer receive message or should setup subscribers durable subscribers assure receive messages @ times.. (http://activemq.apache.org/how-do-durable-queues-and-topics-work.html)

java-ee activemq esb

Comments

Popular posts from this blog

java - How to set log4j.defaultInitOverride property to false in jboss server 6 -

c - GStreamer 1.0 1.4.5 RTSP Example Server sends 503 Service unavailable -

Using ajax with sonata admin list view pagination -