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));