activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From john robens <jrob...@interlated.com.au>
Subject config for InOut messages and restarting the server
Date Sun, 20 Jun 2010 10:56:26 GMT
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