Repository: qpid-jms Updated Branches: refs/heads/master 5c483dbcb -> bdc47a55c
Add destination accessor Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/8efad7c6 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/8efad7c6 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/8efad7c6 Branch: refs/heads/master Commit: 8efad7c651892fef1cd14a910ec2457980722eac Parents: 5c483db Author: Timothy Bish <[email protected]> Authored: Wed Sep 24 14:19:15 2014 -0400 Committer: Timothy Bish <[email protected]> Committed: Wed Sep 24 14:19:43 2014 -0400 ---------------------------------------------------------------------- .../java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/8efad7c6/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java index 3ecb58e..28b989c 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpConsumer.java @@ -30,8 +30,8 @@ import org.apache.qpid.jms.meta.JmsConsumerId; import org.apache.qpid.jms.meta.JmsConsumerInfo; import org.apache.qpid.jms.meta.JmsMessageId; import org.apache.qpid.jms.provider.AsyncResult; -import org.apache.qpid.jms.provider.ProviderListener; import org.apache.qpid.jms.provider.ProviderConstants.ACK_TYPE; +import org.apache.qpid.jms.provider.ProviderListener; import org.apache.qpid.jms.util.IOExceptionSupport; import org.apache.qpid.proton.amqp.Binary; import org.apache.qpid.proton.amqp.DescribedType; @@ -363,6 +363,10 @@ public class AmqpConsumer extends AbstractAmqpResource<JmsConsumerInfo, Receiver return this.info.getConsumerId(); } + public JmsDestination getDestination() { + return this.info.getDestination(); + } + public Receiver getProtonReceiver() { return this.endpoint; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
