Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 4229 invoked from network); 9 Nov 2009 19:55:04 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 9 Nov 2009 19:55:04 -0000 Received: (qmail 96322 invoked by uid 500); 9 Nov 2009 19:55:04 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 96266 invoked by uid 500); 9 Nov 2009 19:55:04 -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 96256 invoked by uid 99); 9 Nov 2009 19:55:04 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 09 Nov 2009 19:55:04 +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; Mon, 09 Nov 2009 19:54:58 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 3C34023888CF; Mon, 9 Nov 2009 19:54:37 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r834195 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Date: Mon, 09 Nov 2009 19:54:37 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20091109195437.3C34023888CF@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: tabish Date: Mon Nov 9 19:54:36 2009 New Revision: 834195 URL: http://svn.apache.org/viewvc?rev=834195&view=rev Log: https://issues.apache.org/activemq/browse/AMQNET-208 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=834195&r1=834194&r2=834195&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 Mon Nov 9 19:54:36 2009 @@ -252,10 +252,10 @@ get { return brokerWireFormatInfo; } } - /// - /// Get/or set the redelivery policy for this connection. - /// - public IRedeliveryPolicy RedeliveryPolicy + /// + /// Get/or set the redelivery policy for this connection. + /// + public IRedeliveryPolicy RedeliveryPolicy { get { return this.redeliveryPolicy; } set { this.redeliveryPolicy = value; } @@ -266,7 +266,7 @@ get { return this.prefetchPolicy; } set { this.prefetchPolicy = value; } } - + #endregion /// @@ -363,7 +363,7 @@ { this.dispatchers.Remove( id ); } - + internal void addProducer( ProducerId id, MessageProducer producer ) { this.producers.Add( id, producer ); @@ -520,6 +520,7 @@ { transport.Oneway(command); } + Tracer.Info("Oneway command sent to broker."); } else { @@ -528,6 +529,7 @@ // the broker can dispose of the object. Allow up to 5 seconds to process. Tracer.Info("Synchronously disposing of Connection."); SyncRequest(command, TimeSpan.FromSeconds(5)); + Tracer.Info("Synchronously closed Connection."); } } catch // (BrokerException) @@ -632,14 +634,14 @@ IDispatcher dispatcher = (IDispatcher) dispatchers[dispatch.ConsumerId]; // Can be null when a consumer has sent a MessagePull and there was - // no available message at the broker to dispatch. + // no available message at the broker to dispatch. if(dispatch.Message != null) { dispatch.Message.ReadOnlyBody = true; dispatch.Message.ReadOnlyProperties = true; dispatch.Message.RedeliveryCounter = dispatch.RedeliveryCounter; } - + dispatcher.Dispatch(dispatch); return; @@ -756,7 +758,7 @@ id.Value = Interlocked.Increment(ref localTransactionCounter); return id; } - + protected SessionInfo CreateSessionInfo(AcknowledgementMode sessionAcknowledgementMode) { SessionInfo answer = new SessionInfo();