You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/07/07 11:45:51 UTC
qpid-broker-j git commit: QPID-7846: Close transaction coordinator
receiving link endpoint on detach
Repository: qpid-broker-j
Updated Branches:
refs/heads/master 167b839a6 -> f98d11843
QPID-7846: Close transaction coordinator receiving link endpoint on detach
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/f98d1184
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/f98d1184
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/f98d1184
Branch: refs/heads/master
Commit: f98d11843cfb0dfef64820973a1e9f4a77018b66
Parents: 167b839
Author: Alex Rudyy <or...@apache.org>
Authored: Fri Jul 7 12:45:25 2017 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Fri Jul 7 12:45:25 2017 +0100
----------------------------------------------------------------------
.../server/protocol/v1_0/TxnCoordinatorReceivingLinkEndpoint.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/f98d1184/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/TxnCoordinatorReceivingLinkEndpoint.java
----------------------------------------------------------------------
diff --git a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/TxnCoordinatorReceivingLinkEndpoint.java b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/TxnCoordinatorReceivingLinkEndpoint.java
index 108943d..2f8887c 100644
--- a/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/TxnCoordinatorReceivingLinkEndpoint.java
+++ b/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/TxnCoordinatorReceivingLinkEndpoint.java
@@ -212,7 +212,7 @@ public class TxnCoordinatorReceivingLinkEndpoint extends AbstractReceivingLinkEn
getSession().incrementRolledBackTransactions();
getSession().getConnection().removeTransaction(entry.getKey());
}
- detach();
+ close();
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org