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 2013/05/17 22:47:15 UTC
svn commit: r1483983 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
Author: tabish
Date: Fri May 17 20:47:14 2013
New Revision: 1483983
URL: http://svn.apache.org/r1483983
Log:
Allow for subclass override to TransactionContext creation.
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs?rev=1483983&r1=1483982&r2=1483983&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs Fri May 17 20:47:14 2013
@@ -72,7 +72,7 @@ namespace Apache.NMS.ActiveMQ
this.acknowledgementMode = acknowledgementMode;
this.requestTimeout = connection.RequestTimeout;
this.dispatchAsync = connection.DispatchAsync;
- this.transactionContext = new TransactionContext(this);
+ this.transactionContext = CreateTransactionContext();
this.exclusive = connection.ExclusiveConsumer;
this.retroactive = connection.UseRetroactiveConsumer;
@@ -1002,6 +1002,11 @@ namespace Apache.NMS.ActiveMQ
}
}
+ protected virtual TransactionContext CreateTransactionContext()
+ {
+ return new TransactionContext(this);
+ }
+
private void CheckClosed()
{
if (closed)