Author: ruwan Date: Sat May 9 08:55:33 2009 New Revision: 35407 URL: http://wso2.org/svn/browse/wso2?view=rev&revision=35407
Log: hidden private services using a parameter Modified: branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOListener.java branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ServerWorker.java Modified: branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOListener.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOListener.java?rev=35407&r1=35406&r2=35407&view=diff ============================================================================== --- branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOListener.java (original) +++ branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/HttpCoreNIOListener.java Sat May 9 08:55:33 2009 @@ -18,17 +18,20 @@ */ package org.apache.synapse.transport.nhttp; +import org.apache.axiom.om.OMElement; import org.apache.axis2.AxisFault; -import org.apache.axis2.engine.AxisObserver; -import org.apache.axis2.engine.AxisConfiguration; -import org.apache.axis2.engine.AxisEvent; import org.apache.axis2.addressing.EndpointReference; import org.apache.axis2.context.ConfigurationContext; import org.apache.axis2.context.MessageContext; import org.apache.axis2.context.SessionContext; import org.apache.axis2.description.*; +import org.apache.axis2.engine.AxisConfiguration; +import org.apache.axis2.engine.AxisEvent; +import org.apache.axis2.engine.AxisObserver; import org.apache.axis2.transport.TransportListener; import org.apache.axis2.transport.base.*; +import org.apache.axis2.transport.base.threads.NativeThreadFactory; +import org.apache.axis2.util.JavaUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.http.impl.nio.reactor.DefaultListeningIOReactor; @@ -41,16 +44,16 @@ import org.apache.http.params.HttpConnectionParams; import org.apache.http.params.HttpParams; import org.apache.http.params.HttpProtocolParams; -import org.apache.axiom.om.OMElement; -import org.apache.axis2.transport.base.threads.NativeThreadFactory; import javax.net.ssl.SSLContext; import java.io.IOException; import java.io.InterruptedIOException; -import java.net.*; +import java.net.InetAddress; +import java.net.InetSocketAddress; +import java.net.UnknownHostException; +import java.util.ArrayList; import java.util.HashMap; import java.util.Map; -import java.util.ArrayList; /** * NIO transport listener for Axis2 based on HttpCore and NIO extensions @@ -530,7 +533,9 @@ } private boolean ignoreService(AxisService service) { - return service.getName().startsWith("__"); // these are "private" services + // these are "private" services + return service.getName().startsWith("__") || JavaUtils.isTrueExplicitly( + service.getParameterValue(NhttpConstants.HIDDEN_SERVICE_PARAM_NAME)); } // -------------- utility methods ------------- Modified: branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java?rev=35407&r1=35406&r2=35407&view=diff ============================================================================== --- branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java (original) +++ branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/NhttpConstants.java Sat May 9 08:55:33 2009 @@ -49,6 +49,8 @@ public static final String SEND_TIMEOUT = "SEND_TIMEOUT"; + public static final String HIDDEN_SERVICE_PARAM_NAME = "hiddenService"; + /** An Axis2 message context property indicating a transport send failure */ public static final String SENDING_FAULT = "SENDING_FAULT"; /** The message context property name which holds the error code for the last encountered exception */ Modified: branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ServerWorker.java URL: http://wso2.org/svn/browse/wso2/branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ServerWorker.java?rev=35407&r1=35406&r2=35407&view=diff ============================================================================== --- branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ServerWorker.java (original) +++ branches/synapse/1.3-wso2v1/modules/transports/core/nhttp/src/main/java/org/apache/synapse/transport/nhttp/ServerWorker.java Sat May 9 08:55:33 2009 @@ -32,6 +32,7 @@ import org.apache.axis2.transport.http.HTTPTransportReceiver; import org.apache.axis2.transport.http.HTTPTransportUtils; import org.apache.axis2.util.MessageContextBuilder; +import org.apache.axis2.util.JavaUtils; import org.apache.axis2.wsdl.WSDLConstants; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -676,7 +677,8 @@ for (Object service : services.values()) { AxisService axisService = (AxisService) service; - if (axisService.getName().startsWith("__")) { + if (axisService.getName().startsWith("__") || JavaUtils.isTrueExplicitly( + axisService.getParameterValue(NhttpConstants.HIDDEN_SERVICE_PARAM_NAME))) { continue; // skip private services } _______________________________________________ Esb-java-dev mailing list [email protected] https://wso2.org/cgi-bin/mailman/listinfo/esb-java-dev
