Repository: qpid-jms Updated Branches: refs/heads/master a15aa6902 -> b6d445f96
QPIDJMS-109 Clear endpoint context when closed during create. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/b6d445f9 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/b6d445f9 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/b6d445f9 Branch: refs/heads/master Commit: b6d445f96e2e16dbdea7252c502ac9712415d104 Parents: a15aa69 Author: Timothy Bish <[email protected]> Authored: Mon Sep 28 17:17:13 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Mon Sep 28 17:17:13 2015 -0400 ---------------------------------------------------------------------- .../qpid/jms/provider/amqp/builders/AmqpResourceBuilder.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b6d445f9/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpResourceBuilder.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpResourceBuilder.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpResourceBuilder.java index eed2b20..6a678ad 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpResourceBuilder.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/builders/AmqpResourceBuilder.java @@ -112,6 +112,7 @@ public abstract class AmqpResourceBuilder<TARGET extends AmqpResource, PARENT ex } else { getEndpoint().close(); getEndpoint().free(); + getEndpoint().setContext(null); // TODO: Perhaps the validate method should thrown an exception so that we // can return a specific error message to the create initiator. @@ -135,6 +136,7 @@ public abstract class AmqpResourceBuilder<TARGET extends AmqpResource, PARENT ex // This resource is now terminated. getEndpoint().close(); getEndpoint().free(); + getEndpoint().setContext(null); getRequest().onFailure(openError); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
