You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2010/11/03 21:33:16 UTC
svn commit: r1030652 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
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);
}
}