Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 33249 invoked from network); 26 Jan 2010 02:29:24 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 26 Jan 2010 02:29:24 -0000 Received: (qmail 6585 invoked by uid 500); 26 Jan 2010 02:29:24 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 6523 invoked by uid 500); 26 Jan 2010 02:29:24 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 6513 invoked by uid 99); 26 Jan 2010 02:29:24 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 26 Jan 2010 02:29:24 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of srodrigu85@gmail.com designates 209.85.220.215 as permitted sender) Received: from [209.85.220.215] (HELO mail-fx0-f215.google.com) (209.85.220.215) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 26 Jan 2010 02:29:13 +0000 Received: by fxm7 with SMTP id 7so770652fxm.8 for ; Mon, 25 Jan 2010 18:28:53 -0800 (PST) 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 :from:date:message-id:subject:to:content-type; bh=U0i8r8+QMCxXaO8xppGWybv/KImFdRRTGfSv8D6qUmA=; b=gfK0STzPahHWwQOWcRlNBULku05frVbHZ5M01GEz9CTL+b5bOEVuy6qOoZIzwNOgUv 1OrAvVn6PVlAC+tnwXLdv2Ddt1dWCt1nLCGqHT8BEidnnEW5+JeIqVWKIZAH24zKyi+p 3147pG02YkU/Tdpon+1H9Z5I4BC5pZ6S1xxzE= 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; b=srdOQEGLc5A/78281spwvcE7CxuPpA9YtiOSCyx9hvZpVMXkU6Vp2+Scly1vsW21tI mZ9DfOpeqWz3tM4yeJ4nu/Z91HJ6OIswVubRieNickcK+zCrX/FD5/AIw4iTBFUfGDB9 k7LGnYIdpx1JS8lNwK4n8mhG/9o3iA44UaJ3I= MIME-Version: 1.0 Received: by 10.223.143.70 with SMTP id t6mr1739080fau.101.1264472933055; Mon, 25 Jan 2010 18:28:53 -0800 (PST) In-Reply-To: References: <1264425884.2355.1.camel@localhost> From: Sebastian Rodriguez Date: Tue, 26 Jan 2010 10:28:33 +0800 Message-ID: Subject: Re: Subscription lost while To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=0023545bd1a400bf07047e080c3f X-Virus-Checked: Checked by ClamAV on apache.org --0023545bd1a400bf07047e080c3f Content-Type: text/plain; charset=ISO-8859-1 >From the log messages I can see: 1/25/2010 9:49:09 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Warn] [6] ActiveMQ.NMS.Warning: Transport failed to tcp://localhost:61616/, attempting to automatically reconnect due to: Unable to read beyond the end of the stream. 0 1/25/2010 9:49:09 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [6] ActiveMQ.NMS.Debug: Transport has been Interrupted. 0 1/25/2010 9:49:09 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Attempting connect to: tcp://localhost:61616/ 0 1/25/2010 9:49:09 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Attempting connect to: tcp://localhost:61616/ 0 1/25/2010 9:49:09 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Opening socket to: localhost on port: 61616 0 1/25/2010 9:49:10 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Connect fail to: tcp://localhost:61616/, reason: Error connecting to localhost:61616. 0 1/25/2010 9:49:10 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Waiting 10ms before attempting connection. 0 1/25/2010 9:49:10 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Attempting connect to: tcp://localhost:61616/ 0 1/25/2010 9:49:10 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Attempting connect to: tcp://localhost:61616/ 0 1/25/2010 9:49:10 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Opening socket to: localhost on port: 61616 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Connect fail to: tcp://localhost:61616/, reason: Error connecting to localhost:61616. 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Waiting 20ms before attempting connection. 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Attempting connect to: tcp://localhost:61616/ 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Attempting connect to: tcp://localhost:61616/ 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Opening socket to: localhost on port: 61616 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Connected to localhost:61616 using InterNetwork protocol. 0 1/25/2010 9:49:12 AM Debug: [ Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Info] [7] ActiveMQ.NMS.Info: Restoring previous transport connection. 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [6] ActiveMQ.NMS.Debug: Parsing type: 1 with: Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller 0 1/25/2010 9:49:12 AM Debug: [ Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Info] [7] ActiveMQ.NMS.Info: Sending queued commands... 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Transport has resumed normal operation. 0 1/25/2010 9:49:12 AM Error: [Dummy.Framework.Notification.ActiveMQ.Tools.TopicConnection.OnConnectionResumedListener] [7] ACTIVEMQ: Connection with Broker Resumed 0 1/25/2010 9:49:12 AM Debug: [Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Debug] [7] ActiveMQ.NMS.Debug: Connection established 0 1/25/2010 9:49:12 AM Debug: [ Dummy.Framework.Notification.ActiveMQ.Tools.ActiveMQTracer.Info] [7] ActiveMQ.NMS.Info: Successfully reconnected to: tcp://localhost:61616/ 0 Is it the normal behavior that we do not receive a ConnectionInterrupted event? What can be the causes to receive the exception Unable to read beyond the end of the stream? I've seen a jira speaking about it ( http://issues.apache.org/activemq/browse/AMQNET-196) but i do not receive this exception in a regular basis. It seems that this exception occurs more often in slow or old machines. Can it be related? Thank you very much for your help on the subject, Sebastien 2010/1/25 Sebastian Rodriguez > I've enabled the logging and left the client running during the night. > Hopefully I'll be able to come back to you tomorrow with more details. > The "funny" thing, is that there is no connection lost, we "only" looses > the subscriptions. > I'll try to make a sample tomorrow see if i can reproduce the error > > 2010/1/25 Timothy Bish > >> On Mon, 2010-01-25 at 12:18 +0800, Sebastian Rodriguez wrote: >> >> > Dear all, >> > I'm encountering a very strange problem. >> > I have a client that uses an embedded broker to connect to a network of >> > brokers. >> > The connection between my client and the embedded broker is done through >> the >> > Apache.NMS.ActiveMQ client. >> > I'm connecting to the embedded broker through a failover uri as I want >> to >> > recover from possible exception raised. >> > The version of the NMS client is 1.2.0.1794 and we are using the latest >> > version from 5.3.1 branch. This was also happening with the stable >> release >> > 5.3.0. >> > >> > Everything works perfectly until I receive the event >> > ConnectionResumedListener. >> > The weird part is that: >> > >> > - why do I receive a connection resume event without a previous >> > connection interrupted event? >> > - the connection is recovered properly, but not my subscription. >> > Basically my client doesnt receive anything anymore from the embedded >> broker >> > although the broker still receives the messages incoming from the >> network of >> > brokers. >> > >> > Do you have any ideas why I would receive a connection resumed alone >> > (without a connection interrupted?), and why the failover transport >> > correctly recovers the connection but not subscriptions? >> > Thank you very much for your advice on the matter, >> > >> >> Can you enable logging and capture some logs around the time the event >> is fired? I have not seen any spurious disconnects as yet from NMS. If >> you have a sample app that can demonstrate the problem that would be >> helpful. >> >> Regards >> Tim. >> >> >> >> >> >> >> -- >> Tim Bish >> http://fusesource.com >> http://timbish.blogspot.com/ >> >> >> >> > > > -- > Sebastien Rodriguez > -- Sebastien Rodriguez --0023545bd1a400bf07047e080c3f--