activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: config for InOut messages and restarting the server
Date Mon, 21 Jun 2010 08:46:28 GMT
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
>

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