You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by di...@apache.org on 2004/02/14 21:46:42 UTC
cvs commit: ws-axis/java/src/org/apache/axis/transport/jms JMSURLHelper.java SimpleJMSListener.java
dims 2004/02/14 12:46:42
Modified: java/src/org/apache/axis/transport/jms JMSURLHelper.java
SimpleJMSListener.java
Log:
Fix for Bug 26549 - SimpleJMSListener not passing connectorProps to endpoint
Fix for Bug 26705 - Correct JMSURLHelper typo and add helper method
Both from jcstaff@apl.jhu.edu (jim)
Revision Changes Path
1.4 +16 -2 ws-axis/java/src/org/apache/axis/transport/jms/JMSURLHelper.java
Index: JMSURLHelper.java
===================================================================
RCS file: /home/cvs/ws-axis/java/src/org/apache/axis/transport/jms/JMSURLHelper.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- JMSURLHelper.java 17 Jan 2004 15:16:59 -0000 1.3
+++ JMSURLHelper.java 14 Feb 2004 20:46:42 -0000 1.4
@@ -115,7 +115,7 @@
if (key.startsWith(JMSConstants._MSG_PROP_PREFIX)) {
key = key.substring(
JMSConstants._MSG_PROP_PREFIX.length());
- addAppplicationProperty(key);
+ addApplicationProperty(key);
}
properties.put(key, value);
}
@@ -178,13 +178,27 @@
/** Adds the name of a property from the url properties that should
* be added to the JMS message.
*/
- public void addAppplicationProperty(String property) {
+ public void addApplicationProperty(String property) {
if (property == null)
return;
if (appProperties == null)
appProperties = new Vector();
+ appProperties.addElement(property);
+ }
+
+ /** Adds the name and value od the application property to the
+ * JMS URL.
+ */
+ public void addApplicationProperty(String property, String value) {
+ if (property == null)
+ return;
+
+ if (appProperties == null)
+ appProperties = new Vector();
+
+ properties.put(property, value);
appProperties.addElement(property);
}
1.9 +3 -1 ws-axis/java/src/org/apache/axis/transport/jms/SimpleJMSListener.java
Index: SimpleJMSListener.java
===================================================================
RCS file: /home/cvs/ws-axis/java/src/org/apache/axis/transport/jms/SimpleJMSListener.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- SimpleJMSListener.java 20 Nov 2003 07:42:53 -0000 1.8
+++ SimpleJMSListener.java 14 Feb 2004 20:46:42 -0000 1.9
@@ -96,6 +96,7 @@
private JMSConnector connector;
private JMSEndpoint endpoint;
private AxisServer server;
+ private HashMap connectorProps;
public SimpleJMSListener(HashMap connectorMap, HashMap cfMap,
String destination, String username,
@@ -112,6 +113,7 @@
username,
password,
adapter);
+ connectorProps = connectorMap;
} catch (Exception e) {
log.error(Messages.getMessage("exception00"), e);
throw e;
@@ -164,7 +166,7 @@
public void start()
throws Exception
{
- endpoint.registerListener(this);
+ endpoint.registerListener(this, connectorProps);
connector.start();
}