summaryrefslogtreecommitdiffstats
path: root/sandbox/rajith/binding.jms/src/main/java/org/apache/tuscany/binding/jms/DefaultOperationSelector.java
diff options
context:
space:
mode:
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.java32
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();
+ }
+ }
+
+
+}