Author: jgomes
Date: Tue Dec 17 15:27:56 2013
New Revision: 1551570
URL: http://svn.apache.org/r1551570
Log:
Minor code cleanup to use the auto-generated accessor function idiom.
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs?rev=1551570&r1=1551569&r2=1551570&view=diff
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
(original)
+++
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
Tue Dec 17 15:27:56 2013
@@ -30,7 +30,6 @@ namespace Apache.NMS.ActiveMQ
{
public class TransactionContext
{
- protected TransactionId transactionId;
protected readonly Session session;
protected readonly Connection connection;
protected readonly ArrayList synchronizations =
ArrayList.Synchronized(new ArrayList());
@@ -43,18 +42,19 @@ namespace Apache.NMS.ActiveMQ
public bool InTransaction
{
- get{ return this.transactionId != null; }
+ get{ return this.TransactionId != null; }
}
public virtual bool InLocalTransaction
{
- get{ return this.transactionId != null; }
+ get{ return this.TransactionId != null; }
}
- public TransactionId TransactionId
- {
- get { return transactionId; }
- }
+ public TransactionId TransactionId
+ {
+ get;
+ protected set;
+ }
public void AddSynchronization(ISynchronization synchronization)
{
@@ -70,11 +70,11 @@ namespace Apache.NMS.ActiveMQ
{
if(!InTransaction)
{
- this.transactionId =
this.session.Connection.CreateLocalTransactionId();
+ this.TransactionId =
this.session.Connection.CreateLocalTransactionId();
TransactionInfo info = new TransactionInfo();
info.ConnectionId = this.session.Connection.ConnectionId;
- info.TransactionId = transactionId;
+ info.TransactionId = this.TransactionId;
info.Type = (int) TransactionType.Begin;
this.session.Connection.Oneway(info);
@@ -83,7 +83,7 @@ namespace Apache.NMS.ActiveMQ
if(Tracer.IsDebugEnabled)
{
- Tracer.Debug("Begin:" + this.transactionId);
+ Tracer.Debug("Begin:" + this.TransactionId);
}
}
}
@@ -96,17 +96,17 @@ namespace Apache.NMS.ActiveMQ
if(Tracer.IsDebugEnabled)
{
- Tracer.Debug("Rollback: " + this.transactionId +
+ Tracer.Debug("Rollback: " + this.TransactionId +
" syncCount: " +
(synchronizations != null ?
synchronizations.Count : 0));
}
TransactionInfo info = new TransactionInfo();
info.ConnectionId = this.session.Connection.ConnectionId;
- info.TransactionId = transactionId;
+ info.TransactionId = this.TransactionId;
info.Type = (int) TransactionType.Rollback;
- this.transactionId = null;
+ this.TransactionId = null;
this.session.Connection.SyncRequest(info);
this.AfterRollback();
@@ -121,17 +121,17 @@ namespace Apache.NMS.ActiveMQ
if(Tracer.IsDebugEnabled)
{
- Tracer.Debug("Commit: " + this.transactionId +
+ Tracer.Debug("Commit: " + this.TransactionId +
" syncCount: " +
(synchronizations != null ?
synchronizations.Count : 0));
}
TransactionInfo info = new TransactionInfo();
info.ConnectionId = this.session.Connection.ConnectionId;
- info.TransactionId = transactionId;
+ info.TransactionId = this.TransactionId;
info.Type = (int) TransactionType.CommitOnePhase;
- this.transactionId = null;
+ this.TransactionId = null;
this.session.Connection.SyncRequest(info);
this.AfterCommit();