diff options
Diffstat (limited to 'sandbox/rajith/binding.jms/src/main/java/org/apache/tuscany/binding/jms/DefaultOperationSelector.java')
-rw-r--r-- | sandbox/rajith/binding.jms/src/main/java/org/apache/tuscany/binding/jms/DefaultOperationSelector.java | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/sandbox/rajith/binding.jms/src/main/java/org/apache/tuscany/binding/jms/DefaultOperationSelector.java b/sandbox/rajith/binding.jms/src/main/java/org/apache/tuscany/binding/jms/DefaultOperationSelector.java new file mode 100644 index 0000000000..fe472e917c --- /dev/null +++ b/sandbox/rajith/binding.jms/src/main/java/org/apache/tuscany/binding/jms/DefaultOperationSelector.java @@ -0,0 +1,32 @@ +package org.apache.tuscany.binding.jms; + +import javax.jms.JMSException; +import javax.jms.Message; + +public class DefaultOperationSelector implements OperationSelector{ + + private JMSBinding jmsBinding; + + public DefaultOperationSelector(JMSBinding jmsBinding){ + this.jmsBinding = jmsBinding; + } + + public String getOperationName(Message message) { + try { + return message.getStringProperty(jmsBinding.getOperationSelectorPropertyName()); + } catch (JMSException e) { + e.printStackTrace(); + return null; + } + } + + public void setOperationName(String operationName,Message message) { + try { + message.setStringProperty(jmsBinding.getOperationSelectorPropertyName(),operationName); + } catch (JMSException e) { + e.printStackTrace(); + } + } + + +} |