You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/09/08 13:28:40 UTC
[1/2] activemq-artemis git commit: This closes #760
Repository: activemq-artemis
Updated Branches:
refs/heads/master c1c20a74f -> a7cac9ba5
This closes #760
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a7cac9ba
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a7cac9ba
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a7cac9ba
Branch: refs/heads/master
Commit: a7cac9ba5cdffaddfcaf6f09e2ca6cb01657444c
Parents: c1c20a7 b788ffa
Author: Clebert Suconic <cl...@apache.org>
Authored: Thu Sep 8 09:27:36 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Thu Sep 8 09:27:36 2016 -0400
----------------------------------------------------------------------
.../org/proton/plug/context/server/ProtonServerSenderContext.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
[2/2] activemq-artemis git commit: ARTEMIS-719 Send ampq:not-found
properly on remote open
Posted by cl...@apache.org.
ARTEMIS-719 Send ampq:not-found properly on remote open
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/b788ffac
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b788ffac
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b788ffac
Branch: refs/heads/master
Commit: b788ffac2259ce4c439eb998b75bd2efd25f25e0
Parents: c1c20a7
Author: Martyn Taylor <mt...@redhat.com>
Authored: Thu Sep 8 11:42:01 2016 +0100
Committer: Clebert Suconic <cl...@apache.org>
Committed: Thu Sep 8 09:27:36 2016 -0400
----------------------------------------------------------------------
.../org/proton/plug/context/server/ProtonServerSenderContext.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b788ffac/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java
index 4ffb2df..564c9ba 100644
--- a/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java
+++ b/artemis-protocols/artemis-proton-plug/src/main/java/org/proton/plug/context/server/ProtonServerSenderContext.java
@@ -164,8 +164,7 @@ public class ProtonServerSenderContext extends AbstractProtonContextSender imple
sender.setSource(source);
}
else {
- sender.setCondition(new ErrorCondition(AmqpError.NOT_FOUND, "Unknown subscription link: " + sender.getName()));
- sender.close();
+ throw new ActiveMQAMQPNotFoundException("Unknown subscription link: " + sender.getName());
}
}
else {