Return-Path: Delivered-To: apmail-camel-users-archive@www.apache.org Received: (qmail 67931 invoked from network); 17 Mar 2009 04:54:31 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 17 Mar 2009 04:54:31 -0000 Received: (qmail 24392 invoked by uid 500); 17 Mar 2009 04:54:31 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 24364 invoked by uid 500); 17 Mar 2009 04:54:31 -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 24353 invoked by uid 99); 17 Mar 2009 04:54:31 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Mar 2009 21:54:31 -0700 X-ASF-Spam-Status: No, hits=0.2 required=10.0 tests=SPF_PASS,WHOIS_MYPRIVREG X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com designates 209.85.220.176 as permitted sender) Received: from [209.85.220.176] (HELO mail-fx0-f176.google.com) (209.85.220.176) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 17 Mar 2009 04:54:22 +0000 Received: by fxm24 with SMTP id 24so3810662fxm.20 for ; Mon, 16 Mar 2009 21:54:00 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :date:message-id:subject:from:to:content-type :content-transfer-encoding; bh=6dixKzV1Te58aXxFJfVOd3QYiBWx6DP/qf03Wi10sfI=; b=XYBdiBd1oFwp93BZUEULE2aGgBsU+L07gQpINy8l+5mboWxafD52zSzSnMNEgWxmm1 Z9VFEYTbmg4J24S+j8JW5yuQxi5X3QeZ//YQCrlDxBoNW99bZouiosTjLJ16TnWrY/Rt pLFne+7HpmaTXdOqdDQjlvoQ59NMXtlyYAP2Q= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type:content-transfer-encoding; b=TgYkWftFQ69ZALfq7Yy68tvPd/uVjT4WtJxNiNBPtIhMjCzgpZ3uYrJvG6qiNEqg2l mAKPgU6U8IcIZrXPY3bwEFMcQMLHrlXo0jyvrrgImZdEI2WsSzTLLQfgbjYZ9JK992+d CMZLTApd0Cp424ah4P22mEHyWjul/ihNB7A+A= MIME-Version: 1.0 Received: by 10.223.117.1 with SMTP id o1mr3966295faq.53.1237265640073; Mon, 16 Mar 2009 21:54:00 -0700 (PDT) In-Reply-To: <22546705.post@talk.nabble.com> References: <22546705.post@talk.nabble.com> Date: Tue, 17 Mar 2009 05:54:00 +0100 Message-ID: <5380c69c0903162154s1a95ee64r1dd661542d31322e@mail.gmail.com> Subject: Re: Camel JMS Component (ActiveMQ) Repeatedly Reconnects From: Claus Ibsen To: users@camel.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable X-Virus-Checked: Checked by ClamAV on apache.org Hi You should use the ActiveMQ component instead of the generic JmsComponent. Its optimized for AMQ. http://camel.apache.org/activemq.html On Mon, Mar 16, 2009 at 9:37 PM, greenbean wrote: > > Apache Camel 2.0 Snapshot > Apache ActiveMQ 5.2 > > When I started Apache Camel I see repeated connect/disconnect events in > activemq. =A0Is there something I have done incorrectly to have activemq = do > this? =A0I use ActiveMQ other places (outside of camel) and everything wo= rks > fine. > > Below is the XML configuration and the DEBUG log information from ActiveM= Q. > -------------------------------------------------------------------------= -------- > > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 class=3D"com.ngc.ident1.example.camel.CamelProcessor"> > =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 class=3D"org.apache.camel.component.jms.JmsComponent"> > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 class=3D"org.apache.activemq.ActiveMQXAConnectionFactory"> > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 = =A0 =A0${local.broker.url} > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 /> > =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 class=3D"org.apache.camel.spring.spi.SpringTransactionPolicy"> > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 class=3D"org.springframework.transaction.support.TransactionTemplate"> > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 ref=3D"transactionManager" /> > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 > =A0 =A0 =A0 =A0 > -------------------------------------------------------------------------= -------- > > 2009-03-16 20:34:08,482 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Task) > Sending: WireFormatInfo { version=3D3, properties=3D{CacheSize=3D1024, > CacheEnabled=3Dtrue, SizePrefixDisabled=3Dfalse, > MaxInactivityDurationInitalDelay=3D10000, TcpNoDelayEnabled=3Dtrue, > MaxInactivityDuration=3D30000, TightEncodingEnabled=3Dtrue, > StackTraceEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > 2009-03-16 20:34:08,485 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport > Initiator: /127.0.0.1:59998) Sending: WireFormatInfo { version=3D3, > properties=3D{CacheSize=3D1024, CacheEnabled=3Dtrue, SizePrefixDisabled= =3Dfalse, > MaxInactivityDurationInitalDelay=3D10000, TcpNoDelayEnabled=3Dtrue, > MaxInactivityDuration=3D30000, TightEncodingEnabled=3Dtrue, > StackTraceEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > 2009-03-16 20:34:08,485 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) Received WireFormat: WireFormatInfo { version=3D3= , > properties=3D{CacheSize=3D1024, CacheEnabled=3Dtrue, SizePrefixDisabled= =3Dfalse, > MaxInactivityDurationInitalDelay=3D10000, TcpNoDelayEnabled=3Dtrue, > MaxInactivityDuration=3D30000, TightEncodingEnabled=3Dtrue, > StackTraceEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > 2009-03-16 20:34:08,485 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) tcp:///127.0.0.1:59998 before negotiation: > OpenWireFormat{version=3D3, cacheEnabled=3Dfalse, stackTraceEnabled=3Dfal= se, > tightEncodingEnabled=3Dfalse, sizePrefixDisabled=3Dfalse} > 2009-03-16 20:34:08,485 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) tcp:///127.0.0.1:59998 after negotiation: > OpenWireFormat{version=3D3, cacheEnabled=3Dtrue, stackTraceEnabled=3Dtrue= , > tightEncodingEnabled=3Dtrue, sizePrefixDisabled=3Dfalse} > 2009-03-16 20:34:08,486 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport: > tcp://localhost/127.0.0.1:61616) Received WireFormat: WireFormatInfo { > version=3D3, properties=3D{CacheSize=3D1024, CacheEnabled=3Dtrue, > SizePrefixDisabled=3Dfalse, MaxInactivityDurationInitalDelay=3D10000, > TcpNoDelayEnabled=3Dtrue, MaxInactivityDuration=3D30000, > TightEncodingEnabled=3Dtrue, StackTraceEnabled=3Dtrue}, magic=3D[A,c,t,i,= v,e,M,Q]} > 2009-03-16 20:34:08,486 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport: > tcp://localhost/127.0.0.1:61616) tcp://localhost/127.0.0.1:61616 before > negotiation: OpenWireFormat{version=3D3, cacheEnabled=3Dfalse, > stackTraceEnabled=3Dfalse, tightEncodingEnabled=3Dfalse, > sizePrefixDisabled=3Dfalse} > 2009-03-16 20:34:08,486 DEBUG > [org.apache.activemq.transport.WireFormatNegotiator] (ActiveMQ Transport: > tcp://localhost/127.0.0.1:61616) tcp://localhost/127.0.0.1:61616 after > negotiation: OpenWireFormat{version=3D3, cacheEnabled=3Dtrue, > stackTraceEnabled=3Dtrue, tightEncodingEnabled=3Dtrue, sizePrefixDisabled= =3Dfalse} > 2009-03-16 20:34:08,486 DEBUG > [org.apache.activemq.broker.TransportConnection] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) Setting up new connection: /127.0.0.1:59998 > 2009-03-16 20:34:08,488 DEBUG > [org.apache.activemq.broker.region.AbstractRegion] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) Adding consumer: > ID:csnwas16-58202-1237234459278-3:1172:-1:1 > 2009-03-16 20:34:08,493 DEBUG > [org.apache.activemq.broker.region.AbstractRegion] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) Adding consumer: > ID:csnwas16-58202-1237234459278-3:1172:1:1 > 2009-03-16 20:34:09,500 DEBUG > [org.apache.activemq.broker.region.AbstractRegion] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) Removing consumer: > ID:csnwas16-58202-1237234459278-3:1172:1:1 > 2009-03-16 20:34:09,500 DEBUG > [org.apache.activemq.store.amq.AMQMessageStore] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) flush starting ... > 2009-03-16 20:34:09,540 DEBUG > [org.apache.activemq.broker.region.AbstractRegion] (ActiveMQ Transport: > tcp:///127.0.0.1:59998) Removing consumer: > ID:csnwas16-58202-1237234459278-3:1172:-1:1 > 2009-03-16 20:34:09,540 DEBUG > [org.apache.activemq.transport.tcp.TcpTransport] > (DefaultMessageListenerContainer-1072) Stopping transport > tcp://localhost/127.0.0.1:61616 > 2009-03-16 20:34:09,541 INFO > [com.ngc.ident1.activemq.transport.orderedfailover.OrderedFailoverTranspo= rt] > (ActiveMQ Transport: tcp://localhost/127.0.0.1:61616) Transport failed, > attempting to automatically reconnect due to: java.net.SocketException: > Socket closed > java.net.SocketException: Socket closed > =A0 =A0 =A0 =A0at java.net.SocketInputStream.socketRead0(Native Method) > =A0 =A0 =A0 =A0at java.net.SocketInputStream.read(SocketInputStream.java:= 129) > =A0 =A0 =A0 =A0at > org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBuffered= InputStream.java:50) > =A0 =A0 =A0 =A0at > org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBuffered= InputStream.java:58) > =A0 =A0 =A0 =A0at java.io.DataInputStream.readInt(DataInputStream.java:37= 0) > =A0 =A0 =A0 =A0at > org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java= :269) > =A0 =A0 =A0 =A0at > org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.j= ava:210) > =A0 =A0 =A0 =A0at > org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:20= 2) > =A0 =A0 =A0 =A0at > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185) > =A0 =A0 =A0 =A0at java.lang.Thread.run(Thread.java:619) > 2009-03-16 20:34:09,542 DEBUG > [org.apache.activemq.broker.TransportConnection] (ActiveMQ Transport > Stopper: /127.0.0.1:59998) Stopping connection: /127.0.0.1:59998 > 2009-03-16 20:34:09,542 DEBUG > [org.apache.activemq.transport.tcp.TcpTransport] (ActiveMQ Transport > Stopper: /127.0.0.1:59998) Stopping transport tcp:///127.0.0.1:59998 > 2009-03-16 20:34:09,542 DEBUG > [org.apache.activemq.broker.TransportConnection] (ActiveMQ Transport > Stopper: /127.0.0.1:59998) Stopped transport: /127.0.0.1:59998 > 2009-03-16 20:34:09,542 DEBUG > [org.apache.activemq.broker.TransportConnection] (ActiveMQ Transport > Stopper: /127.0.0.1:59998) Connection Stopped: /127.0.0.1:59998 > > > > -- > View this message in context: http://www.nabble.com/Camel-JMS-Component-%= 28ActiveMQ%29-Repeatedly-Reconnects-tp22546705p22546705.html > Sent from the Camel - Users (activemq) mailing list archive at Nabble.com= . > > --=20 Claus Ibsen Apache Camel Committer Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/