Skip to content

Commit

Permalink
Create new v1.6.1 release tag
Browse files Browse the repository at this point in the history
  • Loading branch information
Timothy A. Bish committed Oct 16, 2013
2 parents 154894a + 397d182 commit 4ed97af
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 21 deletions.
2 changes: 1 addition & 1 deletion package.ps1
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
# limitations under the License.

$pkgname = "Apache.NMS.ActiveMQ"
$pkgver = "1.6.1"
$pkgver = "1.6.1
$configurations = "release", "debug"
$frameworks = "mono-2.0", "net-2.0", "net-3.5", "net-4.0"
Expand Down
8 changes: 4 additions & 4 deletions src/main/csharp/NetTxTransactionContext.cs
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ public void Prepare(PreparingEnlistment preparingEnlistment)
info.Type = (int)TransactionType.End;

this.connection.CheckConnected();
this.connection.SyncRequest(info);
this.connection.SyncRequest((TransactionInfo) info.Clone());

// Prepare the Transaction for commit.
info.Type = (int)TransactionType.Prepare;
Expand All @@ -214,7 +214,7 @@ public void Prepare(PreparingEnlistment preparingEnlistment)

// if server responds that nothing needs to be done, then reply done.
// otherwise the DTC will call Commit or Rollback but another transaction
// can already be in progress and this one would be commited or rolled back
// can already be in progress and this one would be commited or rolled back
// immediately.
preparingEnlistment.Done();

Expand Down Expand Up @@ -495,7 +495,7 @@ public void InDoubt(Enlistment enlistment)
/// Should be called from NetTxSession when created to check if any TX
/// data is stored for recovery and whether the Broker has matching info
/// stored. If an Transaction is found that belongs to this client and is
/// still alive on the Broker it will be recovered, otherwise the stored
/// still alive on the Broker it will be recovered, otherwise the stored
/// data should be cleared.
/// </summary>
public void InitializeDtcTxContext()
Expand All @@ -515,7 +515,7 @@ public void InitializeDtcTxContext()
if (recoverables.Length == 0)
{
Tracer.Debug("Did not detect any recoverable transactions at Broker.");
// Broker has no recoverable data so nothing to do here, delete the
// Broker has no recoverable data so nothing to do here, delete the
// old recovery log as its stale.
RecoveryLogger.Purge();
return;
Expand Down
16 changes: 0 additions & 16 deletions src/main/csharp/State/ConnectionStateTracker.cs
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,6 @@ public class ConnectionStateTracker : CommandVisitorAdapter
private bool isRestoreTransaction = true;
private bool isTrackMessages = true;
private int maxCacheSize = 256;
private int currentCacheSize;
private readonly LRUCache<Object, Command> messageCache = new LRUCache<Object, Command>(256);

private class RemoveTransactionAction : ResponseHandler
Expand Down Expand Up @@ -90,21 +89,6 @@ public Tracked Track(Command command)

public void TrackBack(Command command)
{
if (command != null)
{
if (TrackMessages && command.IsMessage)
{
Message message = (Message) command;
if(message.TransactionId == null)
{
currentCacheSize = currentCacheSize + 1;
}
}
else if (command.IsMessagePull)
{
currentCacheSize = currentCacheSize + 1;
}
}
}

public void DoRestore(ITransport transport)
Expand Down

0 comments on commit 4ed97af

Please sign in to comment.