delegate back to superclass. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/989bce31 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/989bce31 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/989bce31
Branch: refs/heads/master Commit: 989bce31b2c0404d5760044c97667f19123a8c52 Parents: 5f4acf8 Author: Timothy Bish <tabish...@gmail.com> Authored: Mon Feb 23 17:02:35 2015 -0500 Committer: Timothy Bish <tabish...@gmail.com> Committed: Mon Feb 23 17:02:35 2015 -0500 ---------------------------------------------------------------------- .../jms/provider/amqp/AmqpTemporaryDestination.java | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/989bce31/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTemporaryDestination.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTemporaryDestination.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTemporaryDestination.java index ea105e3..d96099a 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTemporaryDestination.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTemporaryDestination.java @@ -16,6 +16,7 @@ */ package org.apache.qpid.jms.provider.amqp; +import java.io.IOException; import java.util.HashMap; import java.util.Map; @@ -30,7 +31,6 @@ import org.apache.qpid.proton.amqp.messaging.TerminusDurability; import org.apache.qpid.proton.amqp.messaging.TerminusExpiryPolicy; import org.apache.qpid.proton.amqp.transport.ReceiverSettleMode; import org.apache.qpid.proton.amqp.transport.SenderSettleMode; -import org.apache.qpid.proton.engine.EndpointState; import org.apache.qpid.proton.engine.Sender; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -65,18 +65,11 @@ public class AmqpTemporaryDestination extends AmqpAbstractResource<JmsTemporaryD } @Override - public void processStateChange(AmqpProvider provider) { + public void processStateChange(AmqpProvider provider) throws IOException { // TODO - We might want to check on our producer to see if it becomes closed // which might indicate that the broker purged the temporary destination. - EndpointState remoteState = getEndpoint().getRemoteState(); - if (remoteState == EndpointState.ACTIVE) { - LOG.trace("Temporary Destination: {} is now open", this.resource); - opened(); - } else if (remoteState == EndpointState.CLOSED) { - LOG.trace("Temporary Destination: {} is now closed", this.resource); - closed(); - } + super.processStateChange(provider); } @Override --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
