Thanks Dejan - this does exactly what I wanted. If someone knows how to link failover with compression I would be highly appreciative.
This thread seems to end with a dead end: http://osdir.com/ml/users/2010-04/msg01209.html Thanks John On 21 June 2010 18:46, Dejan Bosanac <de...@nighttale.net> wrote: > Hi John, > > try using failover tranposport > > http://activemq.apache.org/failover-transport-reference.html > > Cheers > -- > Dejan Bosanac - http://twitter.com/dejanb > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Sun, Jun 20, 2010 at 12:56 PM, john robens <jrob...@interlated.com.au > >wrote: > > > Hi, wondering if you can help me. > > > > I have a setup with the client as a Grails web-application, communicates > > with a broker embedded in a spring server on the back end. > > > > What I would like to solve, is that if the server is restarted the client > > does not reconnect. > > > > Grails client is configured as follows (resources.groovy): > > > > case "production": > > > > // Not jencks - seems to be out of date. > > // Connect to server. > > _jmsConnectionFactory(ActiveMQConnectionFactory) { > > def server = ConfigurationHolder.config.caller.activemqServer > > brokerURL = server > > } > > > > > jmsConnectionFactory(org.apache.activemq.pool.PooledConnectionFactory) > > { > > connectionFactory = ref('_jmsConnectionFactory') > > } > > > > jmsConfig(org.apache.camel.component.jms.JmsConfiguration) { > > connectionFactory = ref('jmsConnectionFactory') > > transacted = true > > concurrentConsumers = 10 > > } > > > > > activemqServer(org.apache.activemq.camel.component.ActiveMQComponent) > > { > > configuration = ref('jmsConfig') > > } > > > > > > My url just has compression set: > > tcp://server:61616?jms.useCompression=true > > > > > > My messaging call is: > > > > def response = > > > > > camelTemplate.requestBody("activemqServer:queue:checkForNewActivitiesDelta?requestTimeout=${requestTimeout}", > > scoreboard) > > > > My server is setup: > > > > <broker:broker useJmx="false" persistent="false" brokerName="tcp"> > > <broker:destinationPolicy> > > <broker:policyMap> > > <broker:policyEntries> > > <!-- <broker:policyEntry topic=">" > > advisoryForConsumed="true"/> --> > > </broker:policyEntries> > > </broker:policyMap> > > </broker:destinationPolicy> > > > > <broker:transportConnectors> > > <broker:transportConnector name="tcp" uri="${activemq.uri}"/> > > </broker:transportConnectors> > > </broker:broker> > > > > > > It happily processes along. If I kill the server and restart the call to > > requestBody doesn't work: > > > > Server complains with: 'Cannot publish to a deleted destination: > > temp-queue:' > > If I put on full trace logging, I just start getting 'InactivityMonitor' > > messages in the client (Grails side). > > > > I have read some similar posts that say it is a setting I can make with > the > > url called. I have been through ActiveMQ in Action and searched, but it > is > > not obvious to me. > > > > Thanks > > John > > -- > > http://interlated.com.au > > 0434 996 607 > > > -- http://interlated.com.au 0434 996 607
