cxf-commits mailing list archives

[CXF-3574] Support additional JMS property types


Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/61abbdaf
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/61abbdaf
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/61abbdaf

Branch: refs/heads/master
Commit: 61abbdafc1ccec0dce86383c547f4af383afba9a
Parents: 75aecf3
Author: Daniel Kulp <dkulp@apache.org>
Authored: Wed Mar 22 18:39:58 2017 -0400
Committer: Daniel Kulp <dkulp@apache.org>
Committed: Thu Mar 23 08:31:07 2017 -0400

----------------------------------------------------------------------
 .../cxf/transport/jms/JMSMessageUtils.java      | 26 +++++++++++++++++++-
 .../cxf/transport/jms/JMSPropertyType.java      | 19 +++++++-------
 2 files changed, 34 insertions(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/61abbdaf/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSMessageUtils.java
----------------------------------------------------------------------
diff --git a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSMessageUtils.java
b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSMessageUtils.java
index 7f18f95..5e82e9c 100644
--- a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSMessageUtils.java
+++ b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSMessageUtils.java
@@ -384,7 +384,31 @@ final class JMSMessageUtils {
 
         if (messageProperties.isSetProperty()) {
             for (JMSPropertyType prop : messageProperties.getProperty()) {
-                jmsMessage.setStringProperty(prop.getName(), prop.getValue());
+                Object o = prop.getValue();
+                if (o != null) {
+                    Class<?> cls = o.getClass();
+                    if (cls == String.class) {
+                        jmsMessage.setStringProperty(prop.getName(), (String)o);
+                    } else if (cls == Integer.TYPE || cls == Integer.class) {
+                        jmsMessage.setIntProperty(prop.getName(), (Integer)o);
+                    } else if (cls == Double.TYPE || cls == Double.class) {
+                        jmsMessage.setDoubleProperty(prop.getName(), (Double)o);
+                    } else if (cls == Float.TYPE || cls == Float.class) {
+                        jmsMessage.setFloatProperty(prop.getName(), (Float)o);
+                    } else if (cls == Long.TYPE || cls == Long.class) {
+                        jmsMessage.setLongProperty(prop.getName(), (Long)o);
+                    } else if (cls == Boolean.TYPE || cls == Boolean.class) {
+                        jmsMessage.setBooleanProperty(prop.getName(), (Boolean)o);
+                    } else if (cls == Short.TYPE || cls == Short.class) {
+                        jmsMessage.setShortProperty(prop.getName(), (Short)o);
+                    } else if (cls == Byte.TYPE || cls == Byte.class) {
+                        jmsMessage.setShortProperty(prop.getName(), (Byte)o);
+                    } else {
+                        jmsMessage.setObjectProperty(prop.getName(), o);
+                    }
+                } else {
+                    jmsMessage.setStringProperty(prop.getName(), null);
+                }
             }
         }
     }

http://git-wip-us.apache.org/repos/asf/cxf/blob/61abbdaf/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSPropertyType.java
----------------------------------------------------------------------
diff --git a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSPropertyType.java
b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSPropertyType.java
index 0574800..3d9a8f5 100644
--- a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSPropertyType.java
+++ b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSPropertyType.java
@@ -18,34 +18,33 @@
  */
 package org.apache.cxf.transport.jms;
 
-//CHECKSTYLE:OFF
 public class JMSPropertyType {
     protected String name;
-    protected String value;
+    protected Object value;
 
     public String getName() {
         return name;
     }
 
-    public void setName(String value) {
-        this.name = value;
+    public void setName(String name) {
+        this.name = name;
     }
 
     public boolean isSetName() {
-        return (this.name != null);
+        return this.name != null;
     }
 
-    public String getValue() {
+    public Object getValue() {
         return value;
     }
 
-    public void setValue(String value) {
+    public void setValue(Object value) {
         this.value = value;
     }
 
     public boolean isSetValue() {
-        return (this.value != null);
+        return this.value != null;
     }
-
+    
 }
-//CHECKSTYLE:ON
+