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 2005/12/08 06:22:07 UTC
svn commit: r354992 - in
/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms:
JMSSender.java JMSTransport.java
Author: dims
Date: Wed Dec 7 21:21:21 2005
New Revision: 354992
URL: http://svn.apache.org/viewcvs?rev=354992&view=rev
Log:
more garbage collection, adjusted hierarchy a bit as well
Modified:
webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSSender.java
webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSTransport.java
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSSender.java?rev=354992&r1=354991&r2=354992&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSSender.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSSender.java Wed Dec 7 21:21:21 2005
@@ -43,20 +43,24 @@
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;
+import java.util.Iterator;
/**
* This is meant to be used on a SOAP Client to call a SOAP server.
*/
public class JMSSender extends JMSTransport implements TransportSender {
- public JMSSender() {
- }
- public void init(HandlerDescription handlerdesc) {
- //To change body of implemented methods use File | Settings | File Templates.
+ HashMap params = new HashMap();
+
+ public JMSSender() {
}
public void init(ConfigurationContext confContext, TransportOutDescription transportOut) throws AxisFault {
- //To change body of implemented methods use File | Settings | File Templates.
+ Iterator iterator = transportOut.getParameters().iterator();
+ while (iterator.hasNext()) {
+ Parameter param = (Parameter) iterator.next();
+ params.put(param.getName(), param.getValue());
+ }
}
/**
@@ -68,7 +72,7 @@
*/
public void invoke(MessageContext msgContext) throws AxisFault {
JMSConnector connector = null;
- Destination dest = null;
+ Destination dest = null;
if (msgContext.isServerSide()) {
JMSOutTransportInfo transportInfo =
(JMSOutTransportInfo) msgContext.getProperty(
@@ -76,9 +80,9 @@
if (transportInfo != null) {
connector = transportInfo.getConnector();
dest = transportInfo.getDestination();
- }
+ }
}
-
+
boolean waitForResponse = false;
if(connector == null) {
if (msgContext.getProperty(JMSConstants.WAIT_FOR_RESPONSE) != null && msgContext.getProperty(JMSConstants.WAIT_FOR_RESPONSE).equals(Boolean.TRUE))
@@ -88,12 +92,12 @@
super.invoke(msgContext);
}
-
+
try {
JMSEndpoint endpoint = null;
if (dest == null) {
Object destination = msgContext.getProperty(JMSConstants.DESTINATION);
-
+
if(connector == null) {
connector = (JMSConnector) msgContext.getProperty(JMSConstants.CONNECTOR);
}
@@ -108,7 +112,7 @@
throw new AxisFault("noDestination");
}
-
+
if (destination instanceof String) {
endpoint = connector.createEndpoint((String) destination);
} else {
@@ -138,7 +142,7 @@
props.put("contentType", getContentType(msgContext));
props.put("SOAPAction", getSOAPAction(msgContext));
if (waitForResponse) {
- long timeout = Options.DEFAULT_TIMEOUT_MILLISECONDS;
+ long timeout = Options.DEFAULT_TIMEOUT_MILLISECONDS;
if(msgContext.getProperty(JMSConstants.TIMEOUT_TIME) != null) {
timeout = ((Long) msgContext.getProperty(JMSConstants.TIMEOUT_TIME)).longValue();
}
@@ -194,22 +198,6 @@
return props;
}
- public QName getName() {
- return null; //To change body of implemented methods use File | Settings | File Templates.
- }
-
- public Parameter getParameter(String name) {
- return null; //To change body of implemented methods use File | Settings | File Templates.
- }
-
- public void cleanup() throws AxisFault {
- //To change body of implemented methods use File | Settings | File Templates.
- }
-
- public HandlerDescription getHandlerDesc() {
- return null; //To change body of implemented methods use File | Settings | File Templates.
- }
-
public void cleanUp(MessageContext msgContext) throws AxisFault {
//To change body of implemented methods use File | Settings | File Templates.
}
@@ -228,10 +216,10 @@
OMOutputFormat format = new OMOutputFormat();
//Pick the char set encoding from the msgContext
String charSetEnc = (String) msgContext
- .getProperty(MessageContext.CHARACTER_SET_ENCODING);
+ .getProperty(MessageContext.CHARACTER_SET_ENCODING);
format.setDoOptimize(msgContext.isDoingMTOM());
format.setCharSetEncoding(charSetEnc);
- outputMessage.serializeAndConsume(out, format);
+ outputMessage.serializeAndConsume(out, format);
out.flush();
} catch (Exception e) {
throw new AxisFault(e);
@@ -265,7 +253,7 @@
}
format.setSOAP11(msgCtx.isSOAP11());
format.setCharSetEncoding(charSetEnc);
-
+
String encoding = format.getCharSetEncoding();
String contentType = format.getContentType();
if (encoding != null) {
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSTransport.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSTransport.java?rev=354992&r1=354991&r2=354992&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSTransport.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/jms/JMSTransport.java Wed Dec 7 21:21:21 2005
@@ -17,6 +17,7 @@
package org.apache.axis2.transport.jms;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.handlers.AbstractHandler;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.i18n.Messages;
import org.apache.commons.logging.Log;
@@ -34,7 +35,7 @@
* properties are passed in during instantiation and are in turn passed through
* when creating a connector.
*/
-public class JMSTransport {
+public class JMSTransport extends AbstractHandler {
protected static Log log =
LogFactory.getLog(JMSTransport.class.getName());
@@ -42,7 +43,6 @@
private HashMap defaultConnectorProps;
private HashMap defaultConnectionFactoryProps;
- private String transportName;
static {
// add a shutdown hook to close JMS connections
@@ -56,7 +56,6 @@
}
public JMSTransport() {
- transportName = "JMSTransport";
}
// this cons is provided for clients that instantiate the JMSTransport directly