First of all Thank you for all the responses. jms.useAsyncSend=false&jms.maxReconnectAttempts=1 again leads to the invalid parameter exception. As far as I know the paratemeter which can be set thru ActiveMQConnectionFactory are (few of them are show below). I am dont see any parameter which related to maxConnectionRetry . I got the parameter from the source.
Parameter from ActiveMQConnectionFactory disableTimeStampsByDefault; optimizedMessageDispatch = true; copyMessageOnSend = true; useCompression; objectMessageSerializationDefered; useAsyncSend; optimizeAcknowledge; closeTimeout = 15000; useRetroactiveConsumer; exclusiveConsumer; nestedMapAndListEnabled = true; alwaysSyncSend; watchTopicAdvisories = true; producerWindowSize = DEFAULT_PRODUCER_WINDOW_SIZE; warnAboutUnstartedConnectionTimeout = 500L; sendTimeout =0; sendAcksAsync=true; Meise, Christoph wrote: > > Some additions. > > Have a look at > http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHammerTest.java?view=markup > -> createCamelContext(). You can find usages there. For me the following > was minimum to configure maxReconnectAttempts: > > <bean id="activemq" > class="org.apache.activemq.camel.component.ActiveMQComponent"> > <property name="brokerURL" > value="tcp://localhost:61616?jms.useAsyncSend=false&jms.maxReconnectAttempts=1"/> > </bean> > > Regards > Christoph > > > -----Ursprüngliche Nachricht----- > Von: Claus Ibsen [mailto:[email protected]] > Gesendet: Donnerstag, 29. April 2010 12:52 > An: [email protected] > Betreff: Re: AW: activemq component MaxConnection retry > > Hi > > broker. is for embedding a AMQ broker. > > What he is doing is connecting to an existing remote AMQ broker. > I think there is a connection. prefix as well you can use, but I am not > sure > > <property name="brokerURL" > value="tcp://localhost:61616?connection.maxReconnectAttempts=3"/> > > If not you may have to add a 2nd spring bean for the > AMQConnectionFactory and declare the options on it directly. > And then refer to this factory bean in the AMQ component. > > Yes we should have the wiki documentation updated with a working example. > > > > > On Thu, Apr 29, 2010 at 12:25 PM, ssenth <[email protected]> wrote: >> >> HI Christoph, >> >> I did the following <bean id="activemq" >> class="org.apache.activemq.camel.component.ActiveMQComponent"> >> <property name="brokerURL" >> value="tcp://localhost:61616?broker.maxReconnectAttempts=3"/> >> </bean> >> >> But still getting the error as show below >> >> Message: >> Uncategorized exception occured during JMS processing; nested exception >> is >> javax.jms.JMSException: Could not create Transport. Reason: >> java.lang.IllegalArgumentException: Invalid connect parameters: >> {broker.maxReconnectAttempts=3} >> Throwable: >> org.springframework.jms.UncategorizedJmsException: Uncategorized >> exception >> occured during JMS processing; nested exception is >> javax.jms.JMSException: >> Could not create Transport. Reason: java.lang.IllegalArgumentException: >> Invalid connect parameters: {broker.maxReconnectAttempts=3} >> at >> org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:308) >> at >> org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168) >> at >> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:474) >> at >> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:193) >> at >> org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:371) >> at >> org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:316) >> at >> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:150) >> at >> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:65) >> at >> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:63) >> at >> org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:142) >> at >> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:62) >> at >> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:52) >> at >> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:61) >> at >> org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:186) >> at >> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:155) >> at >> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88) >> at >> org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49) >> at >> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:148) >> at org.apache.camel.processor.Pipeline.process(Pipeline.java:73) >> at >> org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:54) >> at >> org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48) >> >> Can you please let me know if you have an idea. >> >> -- >> View this message in context: >> http://old.nabble.com/activemq-component-MaxConnection-retry-tp28386612p28398843.html >> Sent from the Camel - Users mailing list archive at Nabble.com. >> >> > > > > -- > Claus Ibsen > Apache Camel Committer > > Author of Camel in Action: http://www.manning.com/ibsen/ > Open Source Integration: http://fusesource.com > Blog: http://davsclaus.blogspot.com/ > Twitter: http://twitter.com/davsclaus > > -- View this message in context: http://old.nabble.com/activemq-component-MaxConnection-retry-tp28386612p28408488.html Sent from the Camel - Users mailing list archive at Nabble.com.
