You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by as...@apache.org on 2007/10/11 08:37:32 UTC
svn commit: r583695 -
/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSMessageReceiver.java
Author: asankha
Date: Wed Oct 10 23:37:32 2007
New Revision: 583695
URL: http://svn.apache.org/viewvc?rev=583695&view=rev
Log:
Log JMS Text messages if trace level logging is enabled
Set the SOAP Action as urn:<operationName> when JMS messages are mapped to a known operation
Modified:
webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSMessageReceiver.java
Modified: webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSMessageReceiver.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSMessageReceiver.java?rev=583695&r1=583694&r2=583695&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSMessageReceiver.java (original)
+++ webservices/synapse/trunk/java/modules/transports/src/main/java/org/apache/synapse/transport/jms/JMSMessageReceiver.java Wed Oct 10 23:37:32 2007
@@ -28,12 +28,7 @@
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import javax.jms.Destination;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageListener;
-import javax.jms.Queue;
-import javax.jms.Topic;
+import javax.jms.*;
import javax.xml.namespace.QName;
/**
@@ -86,6 +81,9 @@
sb.append("\nCorrelation ID : " + message.getJMSCorrelationID());
sb.append("\nReplyTo ID : " + message.getJMSReplyTo());
log.debug(sb.toString());
+ if (log.isTraceEnabled() && message instanceof TextMessage) {
+ log.trace("\nMessage : " + ((TextMessage) message).getText());
+ }
}
} catch (JMSException e) {
if (log.isDebugEnabled()) {
@@ -164,6 +162,7 @@
AxisOperation operation = service.getOperation(operationQName);
if (operation != null) {
msgContext.setAxisOperation(operation);
+ msgContext.setSoapAction("urn:" + operation.getName().getLocalPart());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org