Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 7084 invoked from network); 3 Nov 2010 20:34:00 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 3 Nov 2010 20:34:00 -0000 Received: (qmail 80963 invoked by uid 500); 3 Nov 2010 20:34:32 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 80883 invoked by uid 500); 3 Nov 2010 20:34:31 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 80875 invoked by uid 99); 3 Nov 2010 20:34:30 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Nov 2010 20:34:30 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 03 Nov 2010 20:34:30 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 92AF423889E7; Wed, 3 Nov 2010 20:33:16 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1030652 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Date: Wed, 03 Nov 2010 20:33:16 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20101103203316.92AF423889E7@eris.apache.org> Author: tabish Date: Wed Nov 3 20:33:16 2010 New Revision: 1030652 URL: http://svn.apache.org/viewvc?rev=1030652&view=rev Log: Allow the CheckConnected method to be accessed by other classes inside the assembly. Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs?rev=1030652&r1=1030651&r2=1030652&view=diff ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs (original) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Wed Nov 3 20:33:16 2010 @@ -32,7 +32,7 @@ namespace Apache.NMS.ActiveMQ public class Connection : IConnection { private static readonly IdGenerator CONNECTION_ID_GENERATOR = new IdGenerator(); - + // Uri configurable options. private AcknowledgementMode acknowledgementMode = AcknowledgementMode.AutoAcknowledge; private bool asyncSend = false; @@ -49,7 +49,7 @@ namespace Apache.NMS.ActiveMQ private readonly Uri brokerUri; private ITransport transport; private readonly ConnectionInfo info; - private TimeSpan requestTimeout; // from connection factory + private TimeSpan requestTimeout; // from connection factory private BrokerInfo brokerInfo; // from broker private readonly CountDownLatch brokerInfoReceived = new CountDownLatch(1); private WireFormatInfo brokerWireFormatInfo; // from broker @@ -131,7 +131,7 @@ namespace Apache.NMS.ActiveMQ } #region Properties - + public String UserName { get { return this.info.UserName; } @@ -653,7 +653,7 @@ namespace Apache.NMS.ActiveMQ } } - protected void CheckConnected() + internal void CheckConnected() { if(closed) { @@ -713,16 +713,16 @@ namespace Apache.NMS.ActiveMQ else if(command is ProducerAck) { ProducerAck ack = (ProducerAck) command as ProducerAck; - if(ack.ProducerId != null) - { + if(ack.ProducerId != null) + { MessageProducer producer = producers[ack.ProducerId] as MessageProducer; - if(producer != null) - { - if(Tracer.IsDebugEnabled) - { - Tracer.Debug("Connection: Received a new ProducerAck -> " + ack); - } - + if(producer != null) + { + if(Tracer.IsDebugEnabled) + { + Tracer.Debug("Connection: Received a new ProducerAck -> " + ack); + } + producer.OnProducerAck(ack); } }