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 2017/03/08 23:12:08 UTC
[06/50] [abbrv] activemq-nms-openwire git commit:
https://issues.apache.org/jira/browse/AMQNET-474
https://issues.apache.org/jira/browse/AMQNET-474
Fire only async error notifications if an error occurs during the transaction operations.
Project: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/commit/2ac8c73b
Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/tree/2ac8c73b
Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/diff/2ac8c73b
Branch: refs/heads/1.6.x
Commit: 2ac8c73b867d6cdffbf530a39cee17abbdc036b2
Parents: c6595f2
Author: Timothy A. Bish <ta...@apache.org>
Authored: Fri Aug 29 15:29:00 2014 +0000
Committer: Timothy A. Bish <ta...@apache.org>
Committed: Fri Aug 29 15:29:00 2014 +0000
----------------------------------------------------------------------
src/main/csharp/NetTxTransactionContext.cs | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/blob/2ac8c73b/src/main/csharp/NetTxTransactionContext.cs
----------------------------------------------------------------------
diff --git a/src/main/csharp/NetTxTransactionContext.cs b/src/main/csharp/NetTxTransactionContext.cs
index 690e95d..c7f5657 100644
--- a/src/main/csharp/NetTxTransactionContext.cs
+++ b/src/main/csharp/NetTxTransactionContext.cs
@@ -252,7 +252,7 @@ namespace Apache.NMS.ActiveMQ
preparingEnlistment.ForceRollback();
try
{
- this.connection.OnException(ex);
+ this.connection.OnAsyncException(ex);
}
catch (Exception error)
{
@@ -301,8 +301,8 @@ namespace Apache.NMS.ActiveMQ
Tracer.DebugFormat("Transaction[{0}] Commit failed with error: {1}",
this.transactionId, ex.Message);
try
- {
- this.connection.OnException(ex);
+ {
+ this.connection.OnAsyncException(ex);
}
catch (Exception error)
{
@@ -362,8 +362,8 @@ namespace Apache.NMS.ActiveMQ
AfterRollback();
enlistment.Done();
try
- {
- this.connection.OnException(ex);
+ {
+ this.connection.OnAsyncException(ex);
}
catch (Exception error)
{
@@ -422,8 +422,8 @@ namespace Apache.NMS.ActiveMQ
this.transactionId, ex.Message);
AfterRollback();
try
- {
- this.connection.OnException(ex);
+ {
+ this.connection.OnAsyncException(ex);
}
catch (Exception error)
{