Rename class variable to avoid conflicting with base class variable.
diff --git a/src/test/csharp/DtcBasicTransactionsTest.cs b/src/test/csharp/DtcBasicTransactionsTest.cs
index cdb917e..b553689 100644
--- a/src/test/csharp/DtcBasicTransactionsTest.cs
+++ b/src/test/csharp/DtcBasicTransactionsTest.cs
@@ -31,15 +31,15 @@
{
base.SetUp();
- this.factory = new NetTxConnectionFactory(ReplaceEnvVar(connectionURI));
- this.factory.ConfiguredResourceManagerId = Guid.NewGuid().ToString();
+ this.dtcFactory = new NetTxConnectionFactory(ReplaceEnvVar(connectionURI));
+ this.dtcFactory.ConfiguredResourceManagerId = Guid.NewGuid().ToString();
}
[Test]
[ExpectedException("Apache.NMS.NMSException")]
public void TestSessionCreateFailsWithInvalidLogLocation()
{
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -57,7 +57,7 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -81,7 +81,7 @@
PurgeDatabase();
PurgeAndFillQueue();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
diff --git a/src/test/csharp/DtcConsumerTransactionsTest.cs b/src/test/csharp/DtcConsumerTransactionsTest.cs
index cbc1892..caa1958 100644
--- a/src/test/csharp/DtcConsumerTransactionsTest.cs
+++ b/src/test/csharp/DtcConsumerTransactionsTest.cs
@@ -36,8 +36,8 @@
{
base.SetUp();
- this.factory = new NetTxConnectionFactory(ReplaceEnvVar(connectionURI));
- this.factory.ConfiguredResourceManagerId = Guid.NewGuid().ToString();
+ this.dtcFactory = new NetTxConnectionFactory(ReplaceEnvVar(connectionURI));
+ this.dtcFactory.ConfiguredResourceManagerId = Guid.NewGuid().ToString();
}
[Test]
@@ -48,7 +48,7 @@
PurgeAndFillQueue();
// receive just one
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.Start();
@@ -111,7 +111,7 @@
PurgeDatabase();
PurgeAndFillQueue(messageCount);
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.Start();
@@ -182,7 +182,7 @@
PurgeDatabase();
PurgeAndFillQueue(messageCount);
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.Start();
@@ -252,7 +252,7 @@
PurgeDatabase();
PurgeAndFillQueue(messageCount);
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
// allow no redelivery so that message immediatly goes to the DLQ if first read fails
connection.RedeliveryPolicy.MaximumRedeliveries = 0;
@@ -319,7 +319,7 @@
PurgeDatabase();
PurgeAndFillQueue();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -351,7 +351,7 @@
PurgeDatabase();
PurgeAndFillQueue();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -383,7 +383,7 @@
PurgeDatabase();
PurgeAndFillQueue(5 * MSG_COUNT);
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -411,7 +411,7 @@
string newConnectionUri =
connectionURI + "?nms.RecoveryPolicy.RecoveryLogger.Location=" + logLocation +
"&nms.configuredResourceManagerId=" +
- factory.ConfiguredResourceManagerId;
+ dtcFactory.ConfiguredResourceManagerId;
// Test initialize - Fills in queue with data to send and clears the DB.
PurgeDatabase();
@@ -424,9 +424,9 @@
Directory.CreateDirectory(logLocation);
- factory = new NetTxConnectionFactory(ReplaceEnvVar(newConnectionUri));
+ dtcFactory = new NetTxConnectionFactory(ReplaceEnvVar(newConnectionUri));
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -460,7 +460,7 @@
PurgeDatabase();
PurgeAndFillQueue();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -485,7 +485,7 @@
PurgeDatabase();
PurgeAndFillQueue();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -515,7 +515,7 @@
PurgeDatabase();
PurgeAndFillQueue();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
ITransport transport = (connection as Connection).ITransport;
TcpFaultyTransport tcpFaulty = transport.Narrow(typeof(TcpFaultyTransport)) as TcpFaultyTransport;
@@ -548,7 +548,7 @@
PurgeDatabase();
PurgeAndFillQueue();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
ITransport transport = (connection as Connection).ITransport;
TcpFaultyTransport tcpFaulty = transport.Narrow(typeof(TcpFaultyTransport)) as TcpFaultyTransport;
@@ -586,7 +586,7 @@
var enlistment = new TestSinglePhaseCommit();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.Start();
@@ -667,7 +667,7 @@
PurgeDatabase();
PurgeAndFillQueue(MSG_COUNT * BATCH_COUNT);
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
using (NetTxSession session = connection.CreateNetTxSession() as NetTxSession)
{
IQueue queue = session.GetQueue(testQueueName);
diff --git a/src/test/csharp/DtcProducerTransactionsTest.cs b/src/test/csharp/DtcProducerTransactionsTest.cs
index b7ba963..260cff4 100644
--- a/src/test/csharp/DtcProducerTransactionsTest.cs
+++ b/src/test/csharp/DtcProducerTransactionsTest.cs
@@ -34,8 +34,8 @@
{
base.SetUp();
- this.factory = new NetTxConnectionFactory(ReplaceEnvVar(connectionURI));
- this.factory.ConfiguredResourceManagerId = Guid.NewGuid().ToString();
+ this.dtcFactory = new NetTxConnectionFactory(ReplaceEnvVar(connectionURI));
+ this.dtcFactory.ConfiguredResourceManagerId = Guid.NewGuid().ToString();
}
[Test]
@@ -44,7 +44,7 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -76,7 +76,7 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -107,11 +107,11 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- NetTxConnectionFactory netTxFactory = factory;
+ NetTxConnectionFactory netTxFactory = dtcFactory;
RecoveryFileLogger logger = netTxFactory.RecoveryPolicy.RecoveryLogger as RecoveryFileLogger;
string logDirectory = logger.Location;
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -151,11 +151,11 @@
string newConnectionUri =
connectionURI + "?nms.RecoveryPolicy.RecoveryLoggerType=harness" +
"&nms.configuredResourceManagerId=" +
- factory.ConfiguredResourceManagerId;
+ dtcFactory.ConfiguredResourceManagerId;
- factory = new NetTxConnectionFactory(ReplaceEnvVar(newConnectionUri));
+ dtcFactory = new NetTxConnectionFactory(ReplaceEnvVar(newConnectionUri));
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
IRecoveryLogger logger = (connection as NetTxConnection).RecoveryPolicy.RecoveryLogger;
Assert.IsNotNull(logger);
@@ -185,7 +185,7 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -213,7 +213,7 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -241,7 +241,7 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -264,7 +264,7 @@
// Test initialize - Fills in DB with data to send.
PrepareDatabase();
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
@@ -292,7 +292,7 @@
[Test]
public void TestIterativeTransactedProduceWithDBDelete()
{
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
connection.ExceptionListener += this.OnException;
connection.Start();
diff --git a/src/test/csharp/DtcTransactionsTestSupport.cs b/src/test/csharp/DtcTransactionsTestSupport.cs
index ddfb394..2ce121f 100644
--- a/src/test/csharp/DtcTransactionsTestSupport.cs
+++ b/src/test/csharp/DtcTransactionsTestSupport.cs
@@ -48,7 +48,7 @@
{
protected const int MSG_COUNT = 5;
protected string nonExistantPath;
- protected NetTxConnectionFactory factory;
+ protected NetTxConnectionFactory dtcFactory;
private ITrace oldTracer;
@@ -326,7 +326,7 @@
protected void VerifyBrokerQueueCount(int expectedCount, string connectionUri)
{
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
// check messages are present in the queue
using (INetTxSession session = connection.CreateNetTxSession())
@@ -398,7 +398,7 @@
protected void VerifyBrokerHasMessagesInQueue(string connectionURI)
{
- using (INetTxConnection connection = factory.CreateNetTxConnection())
+ using (INetTxConnection connection = dtcFactory.CreateNetTxConnection())
{
// check messages are present in the queue
using (INetTxSession session = connection.CreateNetTxSession())
