Author: karthick
Date: Thu May 21 23:00:34 2009
New Revision: 777306

URL: http://svn.apache.org/viewvc?rev=777306&view=rev
Log:
Add an endpoint property that denotes the JMS destination type.

Modified:
    
ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/Properties.java

Modified: 
ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/Properties.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/Properties.java?rev=777306&r1=777305&r2=777306&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/Properties.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/utils/src/main/java/org/apache/ode/utils/Properties.java
 Thu May 21 23:00:34 2009
@@ -86,6 +86,7 @@
     public static final String PROP_SECURITY_POLICY = "security.policy.file";
     public static final String PROP_JMS_REPLY_DESTINATION = 
"jms.reply.destination";
     public static final String PROP_JMS_REPLY_TIMEOUT = "jms.reply.timeout";
+    public static final String PROP_JMS_DESTINATION_TYPE = 
"jms.destination.type";
     public static final String PROP_SEND_WS_ADDRESSING_HEADERS = 
"ws-addressing.headers";
 
 
@@ -197,6 +198,15 @@
                         log.warn("Mal-formatted Property: [" + 
Properties.PROP_JMS_REPLY_TIMEOUT + "=" + value + "]. Long expected. Property 
will be skipped.");
                 }
             }
+            if (properties.containsKey(PROP_JMS_DESTINATION_TYPE)) {
+                String value = properties.get(PROP_JMS_DESTINATION_TYPE);
+                try {
+                    options.setProperty(JMSConstants.DEST_TYPE_PARAM, 
Long.valueOf(value));
+                } catch (NumberFormatException e) {
+                    if (log.isWarnEnabled())
+                        log.warn("Mal-formatted Property: [" + 
Properties.PROP_JMS_DESTINATION_TYPE + "=" + value + "]. Long expected. 
Property will be skipped.");
+                }
+            }
             if(properties.containsKey(PROP_SEND_WS_ADDRESSING_HEADERS)){
                 String value = properties.get(PROP_SEND_WS_ADDRESSING_HEADERS);
                 
options.setProperty(AddressingConstants.DISABLE_ADDRESSING_FOR_OUT_MESSAGES, 
!Boolean.parseBoolean(value));


Reply via email to