Add runtime support for selectors

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@683208 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 1 deletions

diff --git a/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java b/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
index c372d7848e..2e19db86ca 100644
--- a/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
+++ b/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
@@ -133,7 +133,11 @@ public class JMSBindingServiceBindingProvider implements ServiceBindingProvider
             destination = session.createTemporaryQueue();
         }
 
-        consumer = session.createConsumer(destination);
+        if (jmsBinding.getJMSSelector() != null) {
+            consumer = session.createConsumer(destination, jmsBinding.getJMSSelector());
+        } else {
+            consumer = session.createConsumer(destination);
+        }
 
         final JMSBindingListener listener = new JMSBindingListener(jmsBinding, jmsResourceFactory, service);
         try {