activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From john robens <jrob...@interlated.com.au>
Subject Re: config for InOut messages and restarting the server
Date Mon, 12 Jul 2010 03:31:30 GMT
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 <dejan@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 <jrobens@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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message