Author: antelder
Date: Wed Aug 6 03:05:43 2008
New Revision: 683208
URL: http://svn.apache.org/viewvc?rev=683208&view=rev
Log:
Add runtime support for selectors
Modified:
tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
Modified:
tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
URL:
http://svn.apache.org/viewvc/tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java?rev=683208&r1=683207&r2=683208&view=diff
==============================================================================
---
tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
(original)
+++
tuscany/java/sca/modules/binding-jms-runtime/src/main/java/org/apache/tuscany/sca/binding/jms/provider/JMSBindingServiceBindingProvider.java
Wed Aug 6 03:05:43 2008
@@ -133,7 +133,11 @@
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 {
