Author: indika
Date: Fri May 25 06:07:09 2007
New Revision: 541634
URL: http://svn.apache.org/viewvc?view=rev&rev=541634
Log:
add tracing to the ProxyServiceMessageReceiver
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
URL:
http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java?view=diff&rev=541634&r1=541633&r2=541634
==============================================================================
---
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
(original)
+++
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/ProxyServiceMessageReceiver.java
Fri May 25 06:07:09 2007
@@ -22,10 +22,7 @@
import org.apache.axis2.AxisFault;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.apache.synapse.Mediator;
-import org.apache.synapse.MessageContext;
-import org.apache.synapse.SynapseException;
-import org.apache.synapse.FaultHandler;
+import org.apache.synapse.*;
import org.apache.synapse.mediators.MediatorFaultHandler;
import org.apache.synapse.endpoints.Endpoint;
import org.apache.synapse.statistics.impl.ProxyServiceStatisticsStack;
@@ -36,6 +33,7 @@
public class ProxyServiceMessageReceiver extends SynapseMessageReceiver {
private static final Log log =
LogFactory.getLog(ProxyServiceMessageReceiver.class);
+ private static final Log trace = LogFactory.getLog(Constants.TRACE_LOGGER);
/**
* The name of the Proxy Service
@@ -51,7 +49,7 @@
log.debug("WSA-Action: " + (mc.getWSAAction() != null ?
mc.getWSAAction() : "null"));
String[] cids = mc.getAttachmentMap().getAllContentIDs();
if (cids != null && cids.length > 0) {
- for (int i=0; i<cids.length; i++) {
+ for (int i = 0; i < cids.length; i++) {
log.debug("Attachment : " + cids[i]);
}
}
@@ -78,7 +76,11 @@
synCtx.setProperty(org.apache.synapse.Constants.PROXYSERVICE_STATISTICS_STACK,
proxyServiceStatisticsStack);
}
-
+ boolean shouldTrace = (proxy.getTraceState() ==
Constants.TRACING_ON);
+ if (shouldTrace) {
+ trace.trace("Proxy Service " + name + " received a new
message...");
+ trace.trace("Received Message :: " + mc.getEnvelope());
+ }
if (proxy.getTargetFaultSequence() != null) {
Mediator faultSequence =
synCtx.getSequence(proxy.getTargetFaultSequence());
@@ -102,11 +104,14 @@
// Using inSequence for the incoming message mediation
if (proxy.getTargetInSequence() != null) {
-
Mediator inSequence =
synCtx.getSequence(proxy.getTargetInSequence());
if (inSequence != null) {
- log.debug("Using the sequence named "
- + proxy.getTargetInSequence() + " for message
mediation");
+ String msg = "Using the sequence named "
+ + proxy.getTargetInSequence() + " for message
mediation";
+ if (shouldTrace) {
+ trace.trace(msg);
+ }
+ log.debug(msg);
inSequence.mediate(synCtx);
} else {
@@ -116,16 +121,24 @@
"service specified by the name " +
proxy.getTargetInSequence());
}
} else if (proxy.getTargetInLineInSequence() != null) {
- log.debug("Using the anonymous " +
- "in-sequence of the proxy service for message
mediation");
+ String msg = "Using the anonymous " +
+ "in-sequence of the proxy service for message
mediation";
+ if (shouldTrace) {
+ trace.trace(msg);
+ }
+ log.debug(msg);
proxy.getTargetInLineInSequence().mediate(synCtx);
}
if (proxy.getTargetEndpoint() != null) {
Endpoint endpoint =
synCtx.getEndpoint(proxy.getTargetEndpoint());
if (endpoint != null) {
- log.debug("Forwarding message to the endpoint named "
- + proxy.getTargetEndpoint() + " after message
mediation");
+ String msg = "Forwarding message to the endpoint named
"
+ + proxy.getTargetEndpoint() + " after message
mediation";
+ if (shouldTrace) {
+ trace.trace(msg);
+ }
+ log.debug(msg);
endpoint.send(synCtx);
} else {
@@ -135,8 +148,12 @@
"proxy service specified by the name " +
proxy.getTargetEndpoint());
}
} else if (proxy.getTargetInLineEndpoint() != null) {
- log.debug("Forwarding the message to the anonymous " +
- "endpoint of the proxy service after message
mediation");
+ String msg = "Forwarding the message to the anonymous " +
+ "endpoint of the proxy service after message
mediation";
+ if (shouldTrace) {
+ trace.trace(msg);
+ }
+ log.debug(msg);
proxy.getTargetInLineEndpoint().send(synCtx);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
