Return-Path: Delivered-To: apmail-camel-users-archive@www.apache.org Received: (qmail 63850 invoked from network); 30 Apr 2010 10:16:16 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 30 Apr 2010 10:16:16 -0000 Received: (qmail 58387 invoked by uid 500); 30 Apr 2010 10:16:16 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 58264 invoked by uid 500); 30 Apr 2010 10:16:13 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 58256 invoked by uid 99); 30 Apr 2010 10:16:13 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 30 Apr 2010 10:16:13 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com designates 74.125.82.173 as permitted sender) Received: from [74.125.82.173] (HELO mail-wy0-f173.google.com) (74.125.82.173) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 30 Apr 2010 10:16:09 +0000 Received: by wyb35 with SMTP id 35so31641wyb.32 for ; Fri, 30 Apr 2010 03:15:47 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:mime-version:received:in-reply-to :references:from:date:message-id:subject:to:content-type :content-transfer-encoding; bh=+VQx+0gy5v0SCi1kEhp4Jw8RxxkdTvnDpTuA3PH/WNM=; b=T7ZO1wx3rVicNc1YB6rLajq8hsheJcsnglAQeKkl2v9m+NyBKgEULDkJvEHveP/9yK 3Tm0K6yPdawY5tdyQs95qO3alUFHjjmbb3OkQff7diO9hVV7OP9p9c3Kb6JyjkBImj39 0zWSRanIbk6wI7Py0YKj91iM6hFbIM1uinDWM= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type:content-transfer-encoding; b=i9MAI4mETcMJi9+yNs3MSrQ6BrF7H8GANLWrIemQgrdq8IuXqQJsb4qQqqFaLvsRtR lwHcVPqF5d/gLNG454W4t0D2bxs4XpUY6M9fBkkrO1XbK+C09SUCNJSwF+oF150r3h5u ejEzkZc8sJJG4i71rgHIXVuZPpKyk90IM5xHA= Received: by 10.216.87.65 with SMTP id x43mr2303115wee.24.1272622547209; Fri, 30 Apr 2010 03:15:47 -0700 (PDT) MIME-Version: 1.0 Received: by 10.216.25.6 with HTTP; Fri, 30 Apr 2010 03:15:27 -0700 (PDT) In-Reply-To: <28408488.post@talk.nabble.com> References: <28386612.post@talk.nabble.com> <28387714.post@talk.nabble.com> <3EB30F14B02CDF4686DC8C9E1D820A8A04EAD32B@ISDEBLNEXC11.iscout.local> <28398843.post@talk.nabble.com> <3EB30F14B02CDF4686DC8C9E1D820A8A04EAD488@ISDEBLNEXC11.iscout.local> <28408488.post@talk.nabble.com> From: Claus Ibsen Date: Fri, 30 Apr 2010 12:15:27 +0200 Message-ID: Subject: Re: AW: AW: activemq component MaxConnection retry To: users@camel.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Hi Those options was from an unit test which means they work. Maybe you are using and older version of AMQ which do not have those option= s. On Fri, Apr 30, 2010 at 6:43 AM, ssenth wrote: > > First of all Thank you for all the responses. > jms.useAsyncSend=3Dfalse&jms.maxReconnectAttempts=3D1 again leads to the = invalid > parameter exception. As far as I know the paratemeter which can be set th= ru > ActiveMQConnectionFactory are (few of them are show below). I am dont see > any parameter which related to maxConnectionRetry . I got the parameter f= rom > the source. > > Parameter from ActiveMQConnectionFactory > disableTimeStampsByDefault; > optimizedMessageDispatch =3D true; > copyMessageOnSend =3D true; > useCompression; > objectMessageSerializationDefered; > useAsyncSend; > optimizeAcknowledge; > closeTimeout =3D 15000; > useRetroactiveConsumer; > exclusiveConsumer; > nestedMapAndListEnabled =3D true; > alwaysSyncSend; > watchTopicAdvisories =3D true; > producerWindowSize =3D DEFAULT_PRODUCER_WINDOW_SIZE; > warnAboutUnstartedConnectionTimeout =3D 500L; > sendTimeout =3D0; > sendAcksAsync=3Dtrue; > > > > > > Meise, Christoph wrote: >> >> Some additions. >> >> Have a look at >> http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/j= ava/org/apache/camel/component/jms/issues/JmsHammerTest.java?view=3Dmarkup >> -> createCamelContext(). You can find usages there. For me the following >> was minimum to configure maxReconnectAttempts: >> >> > class=3D"org.apache.activemq.camel.component.ActiveMQComponent"> >> =A0 =A0 =A0 =A0 =A0 =A0 =A0 > value=3D"tcp://localhost:61616?jms.useAsyncSend=3Dfalse&jms.maxReconnect= Attempts=3D1"/> >> =A0 =A0 =A0 >> >> Regards >> Christoph >> >> >> -----Urspr=FCngliche Nachricht----- >> Von: Claus Ibsen [mailto:claus.ibsen@gmail.com] >> Gesendet: Donnerstag, 29. April 2010 12:52 >> An: users@camel.apache.org >> 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 >> >> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0value=3D"tcp://localhost:61616?connection.maxReconnectAttempts=3D3"/> >> >> 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 wrote= : >>> >>> HI Christoph, >>> >>> I did the following =A0 =A0 >> class=3D"org.apache.activemq.camel.component.ActiveMQComponent"> >>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0>> value=3D"tcp://localhost:61616?broker.maxReconnectAttempts=3D3"/> >>> =A0 =A0 =A0 =A0 >>> >>> But still getting the error =A0as 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=3D3} >>> 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=3D3} >>> =A0 =A0 =A0 =A0at >>> org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsU= tils.java:308) >>> =A0 =A0 =A0 =A0at >>> org.springframework.jms.support.JmsAccessor.convertJmsAccessException(J= msAccessor.java:168) >>> =A0 =A0 =A0 =A0at >>> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:474) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(J= msConfiguration.java:193) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:371) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.ja= va:316) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:150= ) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.j= ava:65) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.j= ava:63) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:142= ) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:62) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process= (StreamCachingInterceptor.java:52) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.management.InstrumentationProcessor.process(Instrument= ationProcessor.java:61) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.RedeliveryErrorHandler.processExchange(Redel= iveryErrorHandler.java:186) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(R= edeliveryErrorHandler.java:155) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErr= orHandler.java:88) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHand= ler.java:49) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:1= 48) >>> =A0 =A0 =A0 =A0at org.apache.camel.processor.Pipeline.process(Pipeline.= java:73) >>> =A0 =A0 =A0 =A0at >>> org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkPr= ocessor.java:54) >>> =A0 =A0 =A0 =A0at >>> 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-tp28386612= p28398843.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-Ma= xConnection-retry-tp28386612p28408488.html > Sent from the Camel - Users mailing list archive at Nabble.com. > > --=20 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