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 <[email protected]> Authored: Thu Sep 8 11:42:01 2016 +0100 Committer: Clebert Suconic <[email protected]> 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 {
