From activemq-users-return-6343-apmail-geronimo-activemq-users-archive=geronimo.apache.org@geronimo.apache.org Thu Dec 21 07:47:38 2006 Return-Path: Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org Received: (qmail 84094 invoked from network); 21 Dec 2006 07:47:38 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 21 Dec 2006 07:47:38 -0000 Received: (qmail 51610 invoked by uid 500); 21 Dec 2006 07:47:45 -0000 Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org Received: (qmail 51429 invoked by uid 500); 21 Dec 2006 07:47:45 -0000 Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-users@geronimo.apache.org Delivered-To: mailing list activemq-users@geronimo.apache.org Received: (qmail 51420 invoked by uid 99); 21 Dec 2006 07:47:45 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 20 Dec 2006 23:47:45 -0800 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_HELO_PASS X-Spam-Check-By: apache.org Received-SPF: neutral (herse.apache.org: local policy) Received: from [80.67.18.43] (HELO smtprelay05.ispgateway.de) (80.67.18.43) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 20 Dec 2006 23:47:33 -0800 Received: (qmail 28526 invoked from network); 21 Dec 2006 07:47:09 -0000 Received: from unknown (HELO gaia-group.com) (138412@[217.110.20.74]) (envelope-sender ) by smtprelay05.ispgateway.de (qmail-ldap-1.03) with SMTP for ; 21 Dec 2006 07:47:09 -0000 Content-class: urn:content-classes:message MIME-Version: 1.0 Content-Type: text/plain; charset="iso-8859-1" Content-Transfer-Encoding: quoted-printable X-MimeOLE: Produced By Microsoft Exchange V6.5 Subject: AW: Network of brokers Date: Thu, 21 Dec 2006 08:47:07 +0100 Message-ID: <7C36DCD0D35F9A4A8D89A7A8916E755D57F743@GAIA-SERVER.gaia-group.local> In-reply-to: <8000961.post@talk.nabble.com> X-MS-Has-Attach: X-MS-TNEF-Correlator: Thread-Topic: Network of brokers Thread-Index: AcckmgZJ/2JdTLN5RoK5mjEavkLymQAOXr2A From: =?iso-8859-1?Q?Bernhard_Wellh=F6fer?= To: X-Virus-Checked: Checked by ClamAV on apache.org Hello Prashanth, I agree that the clustering/network or brokers feature is not ready for = a productive scenario. The problem is that the ActiveMQ homepage does = not warn you about this case. Therefore again and again people waste = time by trying out this feature - as each new mail for this issue to the = mailing list proves. It's a pity that this as a whole makes ActiveMQ = less trustworthy... Regards, Bernhard =20 > -----Urspr=FCngliche Nachricht----- > Von: Anthrope [mailto:pn@anthrope.com]=20 > Gesendet: Donnerstag, 21. Dezember 2006 01:47 > An: activemq-users@geronimo.apache.org > Betreff: Re: Network of brokers >=20 >=20 > Bernard, >=20 > I agree with you on this. I've posted detailed=20 > questions on clustering/networks or brokers and have met=20 > deafening silence. The folks on this list are very helpful=20 > and willing to share, so I'll hazard a guess that the=20 > clustering/network or brokers feature is simply not ready.=20 > I've tried a ton of different configurations, and none of=20 > them work the way they're supposed to. The documentation=20 > describes a broker cluster as a logical group of clusters,=20 > but the behaviour I see is anything but that. For instance, I=20 > can set things up so that I've got two brokers who know about=20 > each other (via their respective netWorkConnector=20 > specifications), but cannot have a producer produce data on=20 > one broker and a consumer consume data from the other! >=20 > What I have been able to get done is a Master-Slave=20 > configuration using MySQL. But that is painfully slow,=20 > especially if you're dealing with large messages. What I will=20 > do is post my configuration files when I have tweaked and=20 > tuned them to the point that they can work in a production=20 > environment. > Hopefully others will find them useful, even if only as a=20 > starting point. >=20 > Regards, > Prashanth >=20 >=20 > Bernhard2 wrote: > >=20 > > Hello, > >=20 > > I experienced the same problem in my tests. > >=20 > > Who can help Sanne and me here? I'm subscribed to this mailing list=20 > > for some time now. As soon when it comes to help for topics around=20 > > "network of brokers", I noticed that normally nobody is able (or=20 > > wants?) to help. Is a "network of brokers" an uncommon used=20 > feature?=20 > > Regarding to the number of mails for this topic I do not think so. > >=20 > > Thanks and have a nice day, > >=20 > > Bernhard > >=20 > >=20 > >=20 > > sanne wrote: > >>=20 > >> Hi, > >>=20 > >> I'm prototyping an ActiveMQ network of brokers using 4.0.2=20 > RC 6. The=20 > >> setup consists of 2 producers and 2 consumers. At startup=20 > things look=20 > >> fine. After restarting one of the consumers one or more times it=20 > >> stops receiving messages. All the work is done by the=20 > remaining cosumer. > >>=20 > >> The connection dialog of the restarted broker looks o.k., but it=20 > >> doesn't receive messages anymore. > >> (I don't use JmsTemplate) : > >>=20 > >> > >> 2006-10-31 17:12:53,156 DEBUG [ActiveMQ Task] > >> org.apache.activemq.transport.failover.FailoverTransport:=20 > Attempting=20 > >> connect to: tcp://localhost:20002 > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Task] > >> org.apache.activemq.transport.WireFormatNegotiator: Sending: > >> WireFormatInfo { version=3D1, = properties=3D{TightEncodingEnabled=3Dtrue, > >> TcpNoDelayEnabled=3Dtrue, SizePrefixDisabled=3Dfalse,=20 > >> StackTraceEnabled=3Dtrue, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Task] > >> org.apache.activemq.transport.failover.FailoverTransport:=20 > Connection=20 > >> established > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport Server: > >> tcp://dtams0365:20002] > >> org.apache.activemq.transport.WireFormatNegotiator: Sending: > >> WireFormatInfo { version=3D1, = properties=3D{TightEncodingEnabled=3Dtrue, > >> TcpNoDelayEnabled=3Dtrue, SizePrefixDisabled=3Dfalse,=20 > >> StackTraceEnabled=3Dtrue, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:20002] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > Received WireFormat: > >> WireFormatInfo { version=3D1, = properties=3D{StackTraceEnabled=3Dtrue, > >> TightEncodingEnabled=3Dtrue, TcpNoDelayEnabled=3Dtrue,=20 > >> SizePrefixDisabled=3Dfalse, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1411] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > Received WireFormat: > >> WireFormatInfo { version=3D1, = properties=3D{StackTraceEnabled=3Dtrue, > >> TightEncodingEnabled=3Dtrue, TcpNoDelayEnabled=3Dtrue,=20 > >> SizePrefixDisabled=3Dfalse, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:20002] > >> org.apache.activemq.transport.WireFormatNegotiator: > >> tcp://localhost/127.0.0.1:20002 before negotiation: > >> OpenWireFormat{version=3D1, cacheEnabled=3Dfalse,=20 > >> stackTraceEnabled=3Dfalse, tightEncodingEnabled=3Dfalse,=20 > >> sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1411] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > >> tcp:///127.0.0.1:1411 before negotiation:=20 > OpenWireFormat{version=3D1,=20 > >> cacheEnabled=3Dfalse, stackTraceEnabled=3Dfalse,=20 > >> tightEncodingEnabled=3Dfalse, sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:20002] > >> org.apache.activemq.transport.WireFormatNegotiator: > >> tcp://localhost/127.0.0.1:20002 after negotiation: > >> OpenWireFormat{version=3D1, cacheEnabled=3Dtrue,=20 > stackTraceEnabled=3Dtrue,=20 > >> tightEncodingEnabled=3Dtrue, sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,171 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1411] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > >> tcp:///127.0.0.1:1411 after negotiation: = OpenWireFormat{version=3D1,=20 > >> cacheEnabled=3Dtrue, stackTraceEnabled=3Dtrue,=20 > tightEncodingEnabled=3Dtrue,=20 > >> sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport Server: > >> tcp://dtams0365:20002] > >> org.apache.activemq.transport.WireFormatNegotiator: Sending: > >> WireFormatInfo { version=3D1, = properties=3D{TightEncodingEnabled=3Dtrue, > >> TcpNoDelayEnabled=3Dtrue, SizePrefixDisabled=3Dfalse,=20 > >> StackTraceEnabled=3Dtrue, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1406] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > Received WireFormat: > >> WireFormatInfo { version=3D1, = properties=3D{StackTraceEnabled=3Dtrue, > >> TightEncodingEnabled=3Dtrue, TcpNoDelayEnabled=3Dtrue,=20 > >> SizePrefixDisabled=3Dfalse, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1406] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > >> tcp:///127.0.0.1:1406 before negotiation:=20 > OpenWireFormat{version=3D1,=20 > >> cacheEnabled=3Dfalse, stackTraceEnabled=3Dfalse,=20 > >> tightEncodingEnabled=3Dfalse, sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,218 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1406] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > >> tcp:///127.0.0.1:1406 after negotiation: = OpenWireFormat{version=3D1,=20 > >> cacheEnabled=3Dtrue, stackTraceEnabled=3Dtrue,=20 > tightEncodingEnabled=3Dtrue,=20 > >> sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport Server: > >> tcp://dtams0365:20002] > >> org.apache.activemq.transport.WireFormatNegotiator: Sending: > >> WireFormatInfo { version=3D1, = properties=3D{TightEncodingEnabled=3Dtrue, > >> TcpNoDelayEnabled=3Dtrue, SizePrefixDisabled=3Dfalse,=20 > >> StackTraceEnabled=3Dtrue, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1407] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > Received WireFormat: > >> WireFormatInfo { version=3D1, = properties=3D{StackTraceEnabled=3Dtrue, > >> TightEncodingEnabled=3Dtrue, TcpNoDelayEnabled=3Dtrue,=20 > >> SizePrefixDisabled=3Dfalse, MaxInactivityDuration=3D30000,=20 > >> CacheEnabled=3Dtrue}, magic=3D[A,c,t,i,v,e,M,Q]} > >> 2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1407] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > >> tcp:///127.0.0.1:1407 before negotiation:=20 > OpenWireFormat{version=3D1,=20 > >> cacheEnabled=3Dfalse, stackTraceEnabled=3Dfalse,=20 > >> tightEncodingEnabled=3Dfalse, sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,234 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1407] > >> org.apache.activemq.transport.WireFormatNegotiator:=20 > >> tcp:///127.0.0.1:1407 after negotiation: = OpenWireFormat{version=3D1,=20 > >> cacheEnabled=3Dtrue, stackTraceEnabled=3Dtrue,=20 > tightEncodingEnabled=3Dtrue,=20 > >> sizePrefixDisabled=3Dfalse} > >> 2006-10-31 17:12:53,234 DEBUG [Thread-3] > >> org.apache.activemq.broker.region.AbstractRegion: Adding=20 > destination: > >> topic://ActiveMQ.Advisory.Topic > >> 2006-10-31 17:12:53,234 INFO [Thread-4] > >> org.apache.activemq.network.DemandForwardingBridge: Network=20 > >> connection between vm://consumer-002#2 and=20 > >> tcp://localhost:10002(producer-002) has been established. > >> 2006-10-31 17:12:53,234 INFO [Thread-3] > >> org.apache.activemq.network.DemandForwardingBridge: Network=20 > >> connection between vm://consumer-002#0 and=20 > >> tcp://localhost:10001(producer-001) has been established. > >> 2006-10-31 17:12:53,234 DEBUG [main] > >> org.apache.activemq.transport.failover.FailoverTransport: Started. > >> 2006-10-31 17:12:53,265 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1407] > >> org.apache.activemq.broker.region.AbstractRegion: Adding=20 > destination: > >> queue://jmsExample > >> 2006-10-31 17:12:53,281 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:10002] > >> org.apache.activemq.broker.region.AbstractRegion: Adding=20 > destination: > >> queue://jmsExample > >> 2006-10-31 17:12:53,281 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:10001] > >> org.apache.activemq.broker.region.AbstractRegion: Adding=20 > destination: > >> queue://jmsExample > >> 2006-10-31 17:12:53,281 DEBUG [ActiveMQ Transport:=20 > >> tcp:///127.0.0.1:1407] > >> org.apache.activemq.broker.region.AbstractRegion: Adding=20 > destination: > >> topic://ActiveMQ.Advisory.Queue > >> 2006-10-31 17:12:53,296 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:10002] > >> org.apache.activemq.broker.region.AbstractRegion: Adding=20 > destination: > >> topic://ActiveMQ.Advisory.Consumer.Queue.jmsExample > >> 2006-10-31 17:12:53,296 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:10002] > >> org.apache.activemq.network.DemandForwardingBridge:=20 > Forwarding sub on > >> vm://consumer-002#2 from producer-002 : ConsumerInfo=20 > {commandId =3D 3,=20 > >> responseRequired =3D false, consumerId =3D=20 > >> ID:dtams0365-1365-1162311147296-3:1:1:1, destination =3D=20 > >> queue://jmsExample, prefetchSize =3D 1000,=20 > maximumPendingMessageLimit =3D=20 > >> 0, browser =3D false, dispatchAsync =3D true, selector =3D null,=20 > >> subcriptionName =3D null, noLocal =3D false, exclusive =3D false,=20 > >> retroactive =3D false, priority =3D 0, brokerPath =3D=20 > >> [ID:dtams0365-1371-1162311149155-0:0, > >> ID:dtams0365-1365-1162311147296-0:0], optimizedAcknowledge=20 > =3D false,=20 > >> noRangeAcks =3D false, additionalPredicate =3D null} > >> 2006-10-31 17:12:53,296 DEBUG [ActiveMQ Transport: > >> tcp://localhost/127.0.0.1:10001] > >> org.apache.activemq.network.DemandForwardingBridge:=20 > Forwarding sub on=20 > >> vm://consumer-002#0 from producer-001 : ConsumerInfo=20 > {commandId =3D 3,=20 > >> responseRequired =3D false, consumerId =3D=20 > >> ID:dtams0365-1356-1162311143827-3:1:1:1, destination =3D=20 > >> queue://jmsExample, prefetchSize =3D 1000,=20 > maximumPendingMessageLimit =3D=20 > >> 0, browser =3D false, dispatchAsync =3D true, selector =3D null,=20 > >> subcriptionName =3D null, noLocal =3D false, exclusive =3D false,=20 > >> retroactive =3D false, priority =3D 0, brokerPath =3D=20 > >> [ID:dtams0365-1371-1162311149155-0:0, > >> ID:dtams0365-1356-1162311143827-0:0], optimizedAcknowledge=20 > =3D false,=20 > >> noRangeAcks =3D false, additionalPredicate =3D null} > >>=20 > >>=20 > >> The configuration of the brokers is: > >>=20 > >> > >> >> useJmx=3D"false"> > >> =20 > >> > >> > >> > >>=20 > >> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:10001)" failover=3D"true"/> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:10002)" failover=3D"true"/> > >> > >>=20 > >> > >> > >> > >> =20 > >> > >>=20 > >> >> useJmx=3D"false"> > >> =20 > >> > >> > >> > >> >> useJmx=3D"false"> > >> =20 > >> > >> > >> > >>=20 > >> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:20001)" failover=3D"true"/> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:20002)" failover=3D"true"/> > >> > >> =20 > >> > >> > >> > >> =20 > >> > >>=20 > >> >> useJmx=3D"false"> > >> =20 > >> > >> > >> > >>=20 > >> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:20001)" failover=3D"true"/> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:20002)" failover=3D"true"/> > >> > >> =20 > >> > >> > >> > >> =20 > >> > >>=20 > >> >> useJmx=3D"false"> > >> =20 > >> > >> > >> > >>=20 > >> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:20001)" failover=3D"true"/> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:20002)" failover=3D"true"/> > >> > >>=20 > >> > >> > >> > >> =20 > >> > >> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:10001)" failover=3D"true"/> > >> >> dynamicOnly=3D"true" conduitSubscriptions=3D"true" > >> uri=3D"static:(tcp://localhost:10002)" failover=3D"true"/> > >> > >>=20 > >> > >> > >> > >> =20 > >> > >> > >>=20 > >>=20 > >> Has anyone experienced this before, and maybe solved it? > >>=20 > >> Regards, > >>=20 > >> Sanne > >>=20 > >>=20 > >>=20 > >=20 > >=20 >=20 > -- > View this message in context:=20 > http://www.nabble.com/Network-of-brokers-tf2546736.html#a8000961 > Sent from the ActiveMQ - User mailing list archive at Nabble.com. >=20 >=20 >=20 >=20 >=20