diff options
| author | Alex Rudyy <orudyy@apache.org> | 2012-10-24 00:05:45 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2012-10-24 00:05:45 +0000 |
| commit | be39a6c77d321348c8991035ec3d9bb87b99eff3 (patch) | |
| tree | 0ab195eca29a11e7c7afbb1cee1c46ae1ae58042 /qpid/java/client | |
| parent | d1e6de3be23418071a717f08d643593a9040c204 (diff) | |
| download | qpid-python-be39a6c77d321348c8991035ec3d9bb87b99eff3.tar.gz | |
QPID-4389: Send the selector of durable subscriber in arguments of ExchangeBind command
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1401515 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 19 |
1 files changed, 12 insertions, 7 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index e271436c21..12b174198a 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java @@ -53,6 +53,7 @@ import org.apache.qpid.client.messaging.address.AddressHelper; import org.apache.qpid.client.messaging.address.Link; import org.apache.qpid.client.messaging.address.Link.SubscriptionQueue; import org.apache.qpid.client.messaging.address.Node; +import org.apache.qpid.common.AMQPFilterTypes; import org.apache.qpid.exchange.ExchangeDefaults; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.framing.FieldTable; @@ -624,7 +625,9 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic { if (AMQDestination.TOPIC_TYPE == consumer.getDestination().getAddressType()) { - createSubscriptionQueue(consumer.getDestination(), consumer.isNoLocal()); + String selector = consumer.getMessageSelectorFilter() == null? null : consumer.getMessageSelectorFilter().getSelector(); + + createSubscriptionQueue(consumer.getDestination(), consumer.isNoLocal(), selector); queueName = consumer.getDestination().getAMQQueueName(); consumer.setQueuename(queueName); } @@ -1300,8 +1303,8 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic } } } - - void createSubscriptionQueue(AMQDestination dest, boolean noLocal) throws AMQException + + void createSubscriptionQueue(AMQDestination dest, boolean noLocal, String messageSelector) throws AMQException { Link link = dest.getLink(); String queueName = dest.getQueueName(); @@ -1325,12 +1328,14 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic link.isDurable() ? Option.DURABLE : Option.NONE, queueProps.isExclusive() ? Option.EXCLUSIVE : Option.NONE); + Map<String,Object> bindingArguments = new HashMap<String, Object>(); + bindingArguments.put(AMQPFilterTypes.JMS_SELECTOR.getValue().toString(), messageSelector == null ? "" : messageSelector); getQpidSession().exchangeBind(queueName, - dest.getAddressName(), - dest.getSubject(), - Collections.<String,Object>emptyMap()); + dest.getAddressName(), + dest.getSubject(), + bindingArguments); } - + public void setLegacyFieldsForQueueType(AMQDestination dest) { // legacy support |