synapse-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ru...@apache.org
Subject svn commit: r518866 - in /webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2: Axis2SynapseEnvironment.java ProxyServiceMessageReceiver.java
Date Fri, 16 Mar 2007 04:56:37 GMT
Author: ruwan
Date: Thu Mar 15 21:56:37 2007
New Revision: 518866

URL: http://svn.apache.org/viewvc?view=rev&rev=518866
Log:
small spelling mistakes fixed

Modified:
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
    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/Axis2SynapseEnvironment.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java?view=diff&rev=518866&r1=518865&r2=518866
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
(original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
Thu Mar 15 21:56:37 2007
@@ -25,6 +25,7 @@
 import org.apache.synapse.Constants;
 import org.apache.synapse.Mediator;
 import org.apache.synapse.MessageContext;
+import org.apache.synapse.SynapseException;
 import org.apache.synapse.config.SynapseConfiguration;
 import org.apache.synapse.endpoints.utils.EndpointDefinition;
 import org.apache.synapse.core.SynapseEnvironment;
@@ -61,37 +62,41 @@
             StatisticsUtils.processProxyServiceStatistics(synCtx);
             StatisticsUtils.processSequenceStatistics(synCtx);
         }
-        
+
         // if this is a response to a proxy service 
         if (synCtx.getProperty(Constants.PROXY_SERVICE) != null) {
 
-            if (synCtx.getConfiguration().getProxyService((String) synCtx.getProperty(Constants.PROXY_SERVICE))
-                    .getTargetOutSequence() != null) {
+            if (synCtx.getConfiguration().getProxyService((String) synCtx.getProperty(
+                    Constants.PROXY_SERVICE)).getTargetOutSequence() != null) {
 
-                String sequenceName = synCtx.getConfiguration().getProxyService(
-                        (String) synCtx.getProperty(Constants.PROXY_SERVICE)).getTargetOutSequence();
+                String sequenceName = synCtx.getConfiguration().getProxyService((String)
synCtx.
+                        getProperty(Constants.PROXY_SERVICE)).getTargetOutSequence();
                 Mediator outSequence = synCtx.getSequence(sequenceName);
 
                 if (outSequence != null) {
-                    log.debug("Using the sequence named " + sequenceName + " for the outgoing
message mediation of " +
-                            "the proxy service " + synCtx.getProperty(Constants.PROXY_SERVICE));
+                    log.debug("Using the sequence named " + sequenceName
+                            + " for the outgoing message mediation of the proxy service "
+                            + synCtx.getProperty(Constants.PROXY_SERVICE));
                     outSequence.mediate(synCtx);
                 } else {
-                    log.error("Unable to find the sequence specified by the name " + sequenceName);
-                    // TODO invoke a generic synapse error handler for this message
+                    log.error("Unable to find the out-sequence " +
+                            "specified by the name " + sequenceName);
+                    throw new SynapseException("Unable to find the " +
+                            "out-sequence specified by the name " + sequenceName);
                 }
 
             } else if (synCtx.getConfiguration().getProxyService((String) synCtx.getProperty(
                     Constants.PROXY_SERVICE)).getTargetInLineOutSequence() != null) {
 
-                log.debug("Using the anonymous out sequence specified in the proxy service
"
-                        + synCtx.getProperty(Constants.PROXY_SERVICE) + " for out going message
mediation");
+                log.debug("Using the anonymous out-sequence specified in the proxy service
"
+                        + synCtx.getProperty(Constants.PROXY_SERVICE)
+                        + " for outgoing message mediation");
                 synCtx.getConfiguration().getProxyService((String) synCtx.getProperty(
                         Constants.PROXY_SERVICE)).getTargetInLineOutSequence().mediate(synCtx);
             } else {
 
-                log.debug("Proxy service " + synCtx.getProperty(Constants.PROXY_SERVICE)
+ " does not specifies " +
-                        "an out sequence - sending the response back");
+                log.debug("Proxy service " + synCtx.getProperty(Constants.PROXY_SERVICE)
+                        + " does not specifies an out-sequence - sending the response back");
                 Axis2Sender.sendBack(synCtx);
             }
 

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=518866&r1=518865&r2=518866
==============================================================================
--- 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
Thu Mar 15 21:56:37 2007
@@ -60,33 +60,37 @@
             // Setting Required property to collect the proxy service statistics
             boolean statisticsEnable;
             if (proxy != null) {
-                statisticsEnable = (org.apache.synapse.Constants.STATISTICS_ON == proxy.getStatisticsEnable());
+                statisticsEnable = (
+                        org.apache.synapse.Constants.STATISTICS_ON == proxy.getStatisticsEnable());
                 if (statisticsEnable) {
-                    ProxyServiceStatisticsStack proxyServiceStatisticsStack = new ProxyServiceStatisticsStack();
+                    ProxyServiceStatisticsStack proxyServiceStatisticsStack
+                            = new ProxyServiceStatisticsStack();
                     boolean isFault = synCtx.getEnvelope().getBody().hasFault();
-                    proxyServiceStatisticsStack.put(
-                            name, System.currentTimeMillis(), !synCtx.isResponse(), statisticsEnable,
isFault);
-                    synCtx.setProperty(
-                            org.apache.synapse.Constants.PROXYSERVICE_STATISTICS_STACK, proxyServiceStatisticsStack);
+                    proxyServiceStatisticsStack.put(name, System.currentTimeMillis(),
+                            !synCtx.isResponse(), statisticsEnable, isFault);
+                    synCtx.setProperty(org.apache.synapse.Constants.PROXYSERVICE_STATISTICS_STACK,
+                            proxyServiceStatisticsStack);
                 }
 
                 if (proxy.getTargetFaultSequence() != null) {
 
                     Mediator faultSequence = synCtx.getSequence(proxy.getTargetFaultSequence());
                     if (faultSequence != null) {
-                        log.debug("setting the fault sequence of the proxy to context");
+                        log.debug("setting the fault-sequence of the " +
+                                "proxy service to MessageContext");
                         synCtx.pushFaultHandler(new MediatorFaultHandler(
                                 synCtx.getSequence(proxy.getTargetFaultSequence())));
                     } else {
-                        // when we can not find the reference to the fault sequence of the
proxy service we should not
-                        // throw an exception because still we have the global fault sequence
and the message mediation
-                        // can still continue
-                        log.warn("Unable to find the fault sequence for the proxy service
" +
+                        // when we can not find the reference to the fault sequence of the
proxy
+                        // service we should not throw an exception because still we have
the global
+                        // fault sequence and the message mediation can still continue
+                        log.warn("Unable to find the fault-sequence for the proxy service
" +
                                 "specified by the name " + proxy.getTargetFaultSequence());
                     }
                 } else if (proxy.getTargetInLineFaultSequence() != null) {
-                    log.debug("Setting the anonymous fault sequence of the proxy to context");
-                    synCtx.pushFaultHandler(new MediatorFaultHandler(proxy.getTargetInLineFaultSequence()));
+                    log.debug("Setting the anonymous fault-sequence of the proxy to context");
+                    synCtx.pushFaultHandler(
+                            new MediatorFaultHandler(proxy.getTargetInLineFaultSequence()));
                 }
 
                 // Using inSequence for the incoming message mediation
@@ -94,17 +98,19 @@
 
                     Mediator inSequence = synCtx.getSequence(proxy.getTargetInSequence());
                     if (inSequence != null) {
-                        log.debug("Using the sequence named " + proxy.getTargetInSequence()
+ " for message mediation");
+                        log.debug("Using the sequence named "
+                                + proxy.getTargetInSequence() + " for message mediation");
                         inSequence.mediate(synCtx);
                     } else {
 
-                        log.error("Unable to find the in sequence for the proxy service "
+
-                                "specified by the name " + proxy.getTargetInSequence());
-                        throw new SynapseException("Unable to find the in sequence for the
proxy service " +
+                        log.error("Unable to find the in-sequence for the proxy service "
+
                                 "specified by the name " + proxy.getTargetInSequence());
+                        throw new SynapseException("Unable to find the in-sequence for the
proxy " +
+                                "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");
+                    log.debug("Using the anonymous " +
+                            "in-sequence of the proxy service for message mediation");
                     proxy.getTargetInLineInSequence().mediate(synCtx);
                 }
 
@@ -114,26 +120,23 @@
                         log.debug("Forwarding message to the endpoint named "
                                 + proxy.getTargetEndpoint() + " after message mediation");
                         endpoint.send(synCtx);
-                        //synCtx.setTo(new EndpointReference(endpoint.getAddress()));
-                        //Axis2FlexibleMEPClient.send(endpoint, synCtx);
                     } else {
 
                         log.error("Unable to find the endpoint for the proxy service " +
                                 "specified by the name " + proxy.getTargetEndpoint());
-                        throw new SynapseException("Unable to find the endpoint for the proxy
service " +
-                                "specified by the name " + proxy.getTargetEndpoint());
+                        throw new SynapseException("Unable to find the endpoint for the "
+
+                                "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");
                     proxy.getTargetInLineEndpoint().send(synCtx);
-                    //synCtx.setTo(new EndpointReference(proxy.getTargetInLineEndpoint().getAddress()));
-                    //Axis2FlexibleMEPClient.send(proxy.getTargetInLineEndpoint(), synCtx);
                 }
 
             } else {
                 log.error("Proxy Service with the name " + name + " does not exists");
-                throw new SynapseException("Proxy Service with the name " + name + " does
not exists");
+                throw new SynapseException(
+                        "Proxy Service with the name " + name + " does not exists");
             }
         } catch (SynapseException syne) {
             if (!synCtx.getFaultStack().isEmpty()) {



---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org


Mime
View raw message