# PassThroughHttpListener.java

    /**
     *  Copyright (c) 2009, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
     *
     *  Licensed under the Apache License, Version 2.0 (the "License");
     *  you may not use this file except in compliance with the License.
     *  You may obtain a copy of the License at
     *
     *        http://www.apache.org/licenses/LICENSE-2.0
     *
     *  Unless required by applicable law or agreed to in writing, software
     *  distributed under the License is distributed on an "AS IS" BASIS,
     *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     *  See the License for the specific language governing permissions and
     *  limitations under the License.
     */

    package org.apache.synapse.transport.passthru;

    import java.io.IOException;
    import java.net.InetAddress;
    import java.net.InetSocketAddress;
    import java.net.UnknownHostException;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.Comparator;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Locale;
    import java.util.Map;
    import java.util.Set;

    import org.apache.axiom.om.OMElement;
    import org.apache.axis2.AxisFault;
    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.AxisModule;
    import org.apache.axis2.description.AxisService;
    import org.apache.axis2.description.AxisServiceGroup;
    import org.apache.axis2.description.Parameter;
    import org.apache.axis2.description.TransportInDescription;
    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.BaseConstants;
    import org.apache.axis2.transport.base.BaseUtils;
    import org.apache.axis2.transport.base.threads.NativeThreadFactory;
    import org.apache.axis2.transport.base.threads.WorkerPool;
    import org.apache.axis2.transport.base.tracker.AxisServiceFilter;
    import org.apache.axis2.transport.base.tracker.AxisServiceTracker;
    import org.apache.axis2.transport.base.tracker.AxisServiceTrackerListener;
    import org.apache.axis2.util.JavaUtils;
    import org.apache.commons.logging.Log;
    import org.apache.commons.logging.LogFactory;
    import org.apache.http.HttpHost;
    import org.apache.http.impl.nio.reactor.DefaultListeningIOReactor;
    import org.apache.http.nio.reactor.IOReactorException;
    import org.apache.http.nio.reactor.IOReactorExceptionHandler;
    import org.apache.http.params.HttpConnectionParams;
    import org.apache.synapse.transport.http.conn.Scheme;
    import org.apache.synapse.transport.http.conn.ServerConnFactory;
    import org.apache.synapse.transport.nhttp.config.ServerConnFactoryBuilder;
    import org.apache.synapse.transport.passthru.config.PassThroughConfiguration;
    import org.apache.synapse.transport.passthru.config.SourceConfiguration;
    import org.apache.synapse.transport.passthru.core.PassThroughSharedListenerConfiguration;
    import org.apache.synapse.transport.passthru.core.PassThroughListeningIOReactorManager;

    import org.apache.synapse.transport.passthru.jmx.MBeanRegistrar;
    import org.apache.synapse.transport.passthru.jmx.PassThroughTransportMetricsCollector;
    import org.apache.synapse.transport.passthru.jmx.TransportView;

    import org.apache.synapse.transport.passthru.util.ActiveConnectionMonitor;
    import org.apache.synapse.transport.passthru.util.SessionContextUtil;
    import org.apache.synapse.transport.passthru.util.StreamInterceptorsLoader;

    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeUnit;

    /**
     * This is the TransportListener listening for incoming connections. This class start the IOReactor
     * and registers the InRequest Handlers on it.
     */
    public class PassThroughHttpListener implements TransportListener {

        protected Log log = LogFactory.getLog(this.getClass());

        /** The reactor being used */
        private DefaultListeningIOReactor ioReactor;
        /**
         * IOReactor Manager
         */
        private PassThroughListeningIOReactorManager passThroughListeningIOReactorManager;
        /** The protocol handler */
        private SourceHandler handler;
        /** The connection factory */
        private ServerConnFactory connFactory;
        /** The protocol scheme of the listener*/
        private Scheme scheme;
        /** The configuration of the listener */
        private SourceConfiguration sourceConfiguration = null;

        /** The custom URI map for the services if there are any */
        private Map<String, String> serviceNameToEPRMap = new HashMap<String, String>();
        /** The service name map for the custom URI if there are any */
        private Map<String, String> eprToServiceNameMap = new HashMap<String, String>();

        /** the axis observer that gets notified of service life cycle events*/
        //private final AxisObserver axisObserver = new GenericAxisObserver();

        private volatile int state = BaseConstants.STOPPED;

        private String namePrefix;

        /** Active Connection Monitor Scheduler **/
        private final ScheduledExecutorService activeConnectionMonitorScheduler = Executors.newSingleThreadScheduledExecutor();

        /** Delay for ActiveConnectionMonitor **/
        public static final long ACTIVE_CONNECTION_MONITOR_DELAY = 1000;

        /** ServiceTracker to receive updates on services for lifetime management **/
        private AxisServiceTracker serviceTracker;

        private TransportInDescription pttInDescription;

        private ConfigurationContext configurationContext;

        private List<StreamInterceptor> interceptors;

        /**
         * HttpListener Running port
         */
        private  int operatingPort;
        protected Scheme initScheme() {
            return new Scheme("http", 80, false);
        }

        protected ServerConnFactoryBuilder initConnFactoryBuilder(final TransportInDescription transportIn,
                final HttpHost host, ConfigurationContext configurationContext) throws AxisFault {
            return new ServerConnFactoryBuilder(transportIn, host, configurationContext);
        }

        public void init(ConfigurationContext cfgCtx, TransportInDescription transportInDescription)
                throws AxisFault {

            log.info("Initializing Pass-through HTTP/S Listener...");

            this.configurationContext = cfgCtx;
            pttInDescription = transportInDescription;
            namePrefix = transportInDescription.getName().toUpperCase(Locale.US);
            scheme = initScheme();

            int portOffset = Integer.parseInt(System.getProperty("portOffset", "0"));
            Parameter portParam = transportInDescription.getParameter("port");
            int port = Integer.parseInt(portParam.getValue().toString());
            operatingPort = port + portOffset;
            portParam.setValue(String.valueOf(operatingPort));
            portParam.getParameterElement().setText(String.valueOf(operatingPort));

            System.setProperty(transportInDescription.getName() + ".nio.port", String.valueOf(operatingPort));

            Object obj = cfgCtx.getProperty(PassThroughConstants.PASS_THROUGH_TRANSPORT_WORKER_POOL);
            WorkerPool workerPool = null;
            if (obj != null) {
                workerPool = (WorkerPool) obj;
            }

            PassThroughTransportMetricsCollector metrics = new PassThroughTransportMetricsCollector(
                    true, scheme.getName());

            TransportView view = new TransportView(this, null, metrics, null);
            MBeanRegistrar.getInstance().registerMBean(
                    view, "Transport",
                    "passthru-" + namePrefix.toLowerCase() + "-receiver");

            sourceConfiguration = new SourceConfiguration(cfgCtx, transportInDescription, scheme, workerPool, metrics);
            sourceConfiguration.build();

            HttpHost host = new HttpHost(
                    sourceConfiguration.getHostname(),
                    sourceConfiguration.getPort(),
                    sourceConfiguration.getScheme().getName());
            ServerConnFactoryBuilder connFactoryBuilder = initConnFactoryBuilder(transportInDescription, host, cfgCtx);
            connFactory = connFactoryBuilder.build(sourceConfiguration.getHttpParams());

            interceptors = StreamInterceptorsLoader.getInterceptors();
            handler = new SourceHandler(sourceConfiguration , interceptors);
            passThroughListeningIOReactorManager = PassThroughListeningIOReactorManager.getInstance();

            // register to receive updates on services for lifetime management
            //cfgCtx.getAxisConfiguration().addObservers(axisObserver);
            String prefix = namePrefix + "-Listener I/O dispatcher";
            try {
                ioReactor = (DefaultListeningIOReactor) passThroughListeningIOReactorManager.
                        initIOReactor(operatingPort,handler,
                                new PassThroughSharedListenerConfiguration(
                                        new NativeThreadFactory(new ThreadGroup(prefix + " thread group"), prefix),
                                        connFactory, sourceConfiguration));
            } catch (IOReactorException e) {
                handleException("Error initiating " + namePrefix + " ListeningIOReactor", e);
            }

            Map<String, String> o = (Map<String, String>) cfgCtx.getProperty(PassThroughConstants.EPR_TO_SERVICE_NAME_MAP);
            if (o != null) {
                this.eprToServiceNameMap = o;
            } else {
                eprToServiceNameMap = new HashMap<String, String>();
                cfgCtx.setProperty(PassThroughConstants.EPR_TO_SERVICE_NAME_MAP, eprToServiceNameMap);
            }

            cfgCtx.setProperty(PassThroughConstants.PASS_THROUGH_TRANSPORT_WORKER_POOL,
                    sourceConfiguration.getWorkerPool());

            /* register to receive updates on services */
            serviceTracker = new AxisServiceTracker(
                    cfgCtx.getAxisConfiguration(),
                    new AxisServiceFilter() {
                        public boolean matches(AxisService service) {
                            return !service.getName().startsWith("__") // these are "private" services
                                    && BaseUtils.isUsingTransport(service, pttInDescription.getName());
                        }
                    },
                    new AxisServiceTrackerListener() {
                        public void serviceAdded(AxisService service) {
                            addToServiceURIMap(service);
                        }

                        public void serviceRemoved(AxisService service) {
                            removeServiceFfromURIMap(service);
                        }
                    });

        }

        public void start() throws AxisFault {
            serviceTracker.start();
            log.info("Starting Pass-through " + namePrefix + " Listener...");

                String prefix = namePrefix + "-Listener I/O dispatcher";

                passThroughListeningIOReactorManager.startIOReactor(ioReactor,
                        passThroughListeningIOReactorManager.getServerIODispatch(operatingPort), prefix);

                ioReactor.setExceptionHandler(new IOReactorExceptionHandler() {

                    public boolean handle(IOException ioException) {
                        log.warn("System may be unstable: " + namePrefix +
                                " ListeningIOReactor encountered a checked exception : " +
                                ioException.getMessage(), ioException);
                        return true;
                    }

                    public boolean handle(RuntimeException runtimeException) {
                        log.warn("System may be unstable: " + namePrefix +
                                " ListeningIOReactor encountered a runtime exception : "
                                + runtimeException.getMessage(), runtimeException);
                        return true;
                    }
                });
            if(sourceConfiguration.getHttpGetRequestProcessor() != null){
                sourceConfiguration.getHttpGetRequestProcessor().init(sourceConfiguration.getConfigurationContext(), handler);
            }

            startEndpoints();

            state = BaseConstants.STARTED;
        }

        private void startEndpoints() throws AxisFault {

            Set<InetSocketAddress> addressSet = new HashSet<InetSocketAddress>();
            addressSet.addAll(connFactory.getBindAddresses());

            InetAddress bindAddress;
            Parameter bindParam = pttInDescription.getParameter("bind-address");
            if (bindParam != null) {
                try {
                    bindAddress = InetAddress.getByName((String) bindParam.getValue());
                } catch (UnknownHostException ex) {
                    throw AxisFault.makeFault(ex);
                }
                if (bindAddress != null) {
                    Parameter portParam = pttInDescription.getParameter("port");
                    int port = Integer.parseInt(portParam.getValue().toString());
                    addressSet.add(new InetSocketAddress(bindAddress, port));
                }
            }

            if(PassThroughConfiguration.getInstance().getMaxActiveConnections() != -1) {
                addMaxActiveConnectionCountController(PassThroughConfiguration.getInstance().getMaxActiveConnections());
            }

            if (addressSet.isEmpty()) {
                addressSet.add(new InetSocketAddress(Integer.parseInt((String) pttInDescription.getParameter("port").getValue())));
            }

            // Ensure simple but stable order
            List<InetSocketAddress> addressList = new ArrayList<InetSocketAddress>(addressSet);
            Collections.sort(addressList, new Comparator<InetSocketAddress>() {

                public int compare(InetSocketAddress a1, InetSocketAddress a2) {
                    String s1 = a1.toString();
                    String s2 = a2.toString();
                    return s1.compareTo(s2);
                }

            });
            for (InetSocketAddress address: addressList) {
                passThroughListeningIOReactorManager.startPTTEndpoint(address, ioReactor, namePrefix);
            }
        }

        /**
         * Start specified end points for given set of bind addresses
         *
         * @param bindAddresses InetSocketAddress list to be started
         * @throws AxisFault
         */
        private void startSpecificEndpoints(Set<InetSocketAddress> bindAddresses) throws AxisFault {

            if (PassThroughConfiguration.getInstance().getMaxActiveConnections() != -1) {
                addMaxActiveConnectionCountController(PassThroughConfiguration.getInstance().getMaxActiveConnections());
            }

            List<InetSocketAddress> addressList = new ArrayList<InetSocketAddress>(bindAddresses);
            Collections.sort(addressList, new Comparator<InetSocketAddress>() {

                public int compare(InetSocketAddress a1, InetSocketAddress a2) {
                    String s1 = a1.toString();
                    String s2 = a2.toString();
                    return s1.compareTo(s2);
                }

            });
            for (InetSocketAddress address : addressList) {
                passThroughListeningIOReactorManager.startPTTEndpoint(address, ioReactor, namePrefix);
            }
        }

        private void handleException(String s, Exception e) throws AxisFault {
            log.error(s, e);
            throw new AxisFault(s, e);
        }

        /**
         *  Pauses the IOReactor if maxActive count exceeds the configured value.
         * @param maxActiveConnections
         */
        private void addMaxActiveConnectionCountController(int maxActiveConnections) {
            ActiveConnectionMonitor activeConnectionMonitor = new ActiveConnectionMonitor(sourceConfiguration.getMetrics(), ioReactor, maxActiveConnections);
            activeConnectionMonitorScheduler.scheduleWithFixedDelay(activeConnectionMonitor, 0, ACTIVE_CONNECTION_MONITOR_DELAY, TimeUnit.MILLISECONDS);
        }

        public EndpointReference getEPRForService(String serviceName, String ip) throws AxisFault {
            String trailer = "";
            //Strip out the operation name
            if (serviceName.indexOf('/') != -1) {
                trailer += serviceName.substring(serviceName.indexOf("/"));
                serviceName = serviceName.substring(0, serviceName.indexOf('/'));
            }
            // strip out the endpoint name if present
            if (serviceName.indexOf('.') != -1) {
                trailer += serviceName.substring(serviceName.indexOf("."));
                serviceName = serviceName.substring(0, serviceName.indexOf('.'));
            }

            if (serviceNameToEPRMap.containsKey(serviceName)) {
                return new EndpointReference(
                        sourceConfiguration.getCustomEPRPrefix() +
                                serviceNameToEPRMap.get(serviceName) + trailer);
            } else {
                return new EndpointReference(sourceConfiguration.getServiceEPRPrefix() +
                        serviceName + trailer);
            }
        }

        /**
         * Return the EPRs for the given service over this transport
         * @param serviceName name of the service
         * @param ip IP address
         * @return the EndpointReferences for this service over the transport
         * @throws AxisFault on error
         */
        public EndpointReference[] getEPRsForService(String serviceName, String ip) throws AxisFault {
            String trailer = "";
            boolean isServiceWithCustomURI = isServiceWithCustomURI(serviceName);
            //Strip out the operation name
            if (serviceName.indexOf('/') != -1) {
                trailer += serviceName.substring(serviceName.indexOf("/"));
                serviceName = serviceName.substring(0, serviceName.indexOf('/'));
            }
            // strip out the endpoint name if present
            if (serviceName.indexOf('.') != -1 && !isServiceWithCustomURI) {
                trailer += serviceName.substring(serviceName.indexOf("."));
                serviceName = serviceName.substring(0, serviceName.indexOf('.'));
            }else if(isServiceWithCustomURI){
                serviceName = getServiceNameFromServiceWithCustomURI(serviceName);
            }

            EndpointReference[] endpointReferences = new EndpointReference[1];
            if (serviceNameToEPRMap.containsKey(serviceName)) {
                endpointReferences[0] = new EndpointReference(
                        sourceConfiguration.getCustomEPRPrefix() +
                                serviceNameToEPRMap.get(serviceName) + trailer);
            } else {
                endpointReferences[0]
                        = new EndpointReference(sourceConfiguration.getServiceEPRPrefix() +
                        serviceName + trailer);
            }
            return endpointReferences;
        }

        public SessionContext getSessionContext(MessageContext messageContext) {
            return SessionContextUtil.createSessionContext(messageContext);
        }

        public void stop() throws AxisFault {
            if (state == BaseConstants.STOPPED) return;
            log.info("Stopping Pass-through " + namePrefix + " Listener..");
            try {
                int wait = PassThroughConfiguration.getInstance().getListenerShutdownWaitTime();
                passThroughListeningIOReactorManager.pauseIOReactor(operatingPort);
                if (wait > 0) {
                    log.info("Waiting " + wait/1000 + " seconds to cleanup active connections...");
                    Thread.sleep(wait);
                    passThroughListeningIOReactorManager.shutdownIOReactor(operatingPort, wait);
                } else {
                    boolean isGracefulShutdownEnabled = Boolean.parseBoolean(
                            System.getProperty("gracefulShutdown", "true"));
                    if (isGracefulShutdownEnabled) {
                        long so_timeout = PassThroughConfiguration.getInstance()
                                .getIntProperty(HttpConnectionParams.SO_TIMEOUT, Pipe.DEFAULT_TIME_OUT_VALUE);
                        passThroughListeningIOReactorManager.shutdownIOReactor(
                                operatingPort, sourceConfiguration, so_timeout);
                    } else {
                        passThroughListeningIOReactorManager.shutdownIOReactor(operatingPort);
                    }
                }
                serviceTracker.stop();
                handler.stop();
            } catch (IOException e) {
                handleException("Error shutting down " + namePrefix + " listening IO reactor", e);
            } catch (InterruptedException e) {
                handleException("Error waiting for connection drain", e);
            } finally {
                state = BaseConstants.STOPPED;
            }
        }

        public void destroy() {
            log.info("Destroying PassThroughHttpListener");
           /* sourceConfiguration.getConfigurationContext().
                    getAxisConfiguration().getObserversList().remove(axisObserver);*/
    //        serviceTracker.stop();
            sourceConfiguration.getMetrics().destroy();
        }

        /**
         * Pause the listener - Stops accepting new connections, but continues processing existing
         * connections until they complete. This helps bring an instance into a maintenance mode
         *
         * @throws AxisFault if pausing fails
         */
        public void pause() throws AxisFault {
            if (state != BaseConstants.STARTED) return;
            try {
               passThroughListeningIOReactorManager.pauseIOReactor(operatingPort);

                state = BaseConstants.PAUSED;
                log.info(namePrefix + " Listener Paused");
            } catch (IOException e) {
                handleException("Error pausing IOReactor", e);
            }
        }

        /**
         * Resume the lister - Brings the lister into active mode back from a paused state
         *
         * @throws AxisFault if the resume fails
         */
        public void resume() throws AxisFault {
            if (state != BaseConstants.PAUSED) return;
            try {
                passThroughListeningIOReactorManager.resumeIOReactor(operatingPort);
                state = BaseConstants.STARTED;
                log.info(namePrefix + " Listener Resumed");
            } catch (IOException e) {
                handleException("Error resuming IOReactor", e);
            }
        }

        public void reload(final TransportInDescription transportIn) throws AxisFault {
            if (state != BaseConstants.STARTED) return;

            // Close all listener endpoints and stop accepting new connections
           passThroughListeningIOReactorManager.closeAllPTTListenerEndpoints(operatingPort);

            // Rebuild connection factory
            HttpHost host = new HttpHost(
                    sourceConfiguration.getHostname(),
                    sourceConfiguration.getPort(),
                    sourceConfiguration.getScheme().getName());
            ServerConnFactoryBuilder connFactoryBuilder = initConnFactoryBuilder(transportIn, host,
                    this.configurationContext);
            connFactory = connFactoryBuilder.build(sourceConfiguration.getHttpParams());
            passThroughListeningIOReactorManager.getServerIODispatch(operatingPort).update(connFactory);

            startEndpoints();

            log.info(namePrefix + " Reloaded");
        }

        /**
         * Re-load specific end points given in Transport In Description
         *
         * @param transportIn TransportInDescriptions of the new configuration
         * @throws AxisFault
         */
        public void reloadSpecificEndPoints(final TransportInDescription transportIn) throws AxisFault {
            if (state != BaseConstants.STARTED) {
                return;
            }

            HttpHost host = new HttpHost(
                    sourceConfiguration.getHostname(),
                    sourceConfiguration.getPort(),
                    sourceConfiguration.getScheme().getName());
            // Rebuild connection factory
            ServerConnFactoryBuilder connFactoryBuilder = initConnFactoryBuilder(transportIn, host,
                    this.configurationContext);
            connFactory = connFactoryBuilder.build(sourceConfiguration.getHttpParams());

            // Close listener endpoints and stop accepting new connections
            passThroughListeningIOReactorManager.closeSpecificPTTListenerEndpoints(operatingPort, connFactory.getBindAddresses());
            passThroughListeningIOReactorManager.getServerIODispatch(operatingPort).update(connFactory);

            //start end points from new configuration
            startSpecificEndpoints(connFactory.getBindAddresses());

            log.info(namePrefix + " Reloaded");
        }

        /**
         * Stop accepting new connections, and wait the maximum specified time for in-flight
         * requests to complete before a controlled shutdown for maintenance
         *
         * @param milliSecs number of milliseconds to wait until pending requests complete
         * @throws AxisFault if the shutdown fails
         */
        public void maintenanceShutdown(long milliSecs) throws AxisFault {
            if (state != BaseConstants.STARTED) return;
            try {
                long start = System.currentTimeMillis();
                passThroughListeningIOReactorManager.pauseIOReactor(operatingPort);
                passThroughListeningIOReactorManager.shutdownIOReactor(operatingPort, milliSecs);
                state = BaseConstants.STOPPED;
                serviceTracker.stop();
                log.info("Listener shutdown in : " + (System.currentTimeMillis() - start) / 1000 + "s");
            } catch (IOException e) {
                handleException("Error shutting down the IOReactor for maintenance", e);
            }
        }

        /**
         * An AxisObserver which will start listening for newly deployed or started services,
         * and stop listening when services are un-deployed or stopped.
         */
        private class GenericAxisObserver implements AxisObserver {
            public void init(AxisConfiguration axisConfig) {}

            public void serviceUpdate(AxisEvent event, AxisService service) {
                if (!ignoreService(service)
                        && BaseUtils.isUsingTransport(service,
                        sourceConfiguration.getInDescription().getName())) {
                    switch (event.getEventType()) {
                        case AxisEvent.SERVICE_DEPLOY :
                            addToServiceURIMap(service);
                            System.out.println("SERVICE_DEPLOY");
                            break;
                        case AxisEvent.SERVICE_REMOVE :
                            removeServiceFfromURIMap(service);
                            System.out.println("SERVICE_REMOVE");
                            break;
                        case AxisEvent.SERVICE_START  :
                            addToServiceURIMap(service);
                            System.out.println("SERVICE_START");
                            break;
                        case AxisEvent.SERVICE_STOP   :
                            removeServiceFfromURIMap(service);
                            System.out.println("SERVICE_STOP");
                            break;
                    }
                }
            }

            public void moduleUpdate(AxisEvent event, AxisModule module) {}
            public void addParameter(Parameter parameter) throws AxisFault {}
            public void removeParameter(Parameter parameter) throws AxisFault {}
            public void deserializeParameters(OMElement parameterElement) throws AxisFault {}
            public Parameter getParameter(String name) { return null; }
            public ArrayList<Parameter> getParameters() { return null; }
            public boolean isParameterLocked(String parameterName) { return false; }
            public void serviceGroupUpdate(AxisEvent event, AxisServiceGroup serviceGroup) {}
        }

        private boolean ignoreService(AxisService service) {
            // these are "private" services
            return service.getName().startsWith("__") || JavaUtils.isTrueExplicitly(
                    service.getParameter(PassThroughConstants.HIDDEN_SERVICE_PARAM_NAME));
        }

        private void addToServiceURIMap(AxisService service) {
            Parameter param = service.getParameter(PassThroughConstants.SERVICE_URI_LOCATION);
            if (param != null) {
                String uriLocation = param.getValue().toString();
                if (uriLocation.startsWith("/")) {
                    uriLocation = uriLocation.substring(1);
                }
                serviceNameToEPRMap.put(service.getName(), uriLocation);
                eprToServiceNameMap.put(uriLocation, service.getName());
            }
        }

        private void removeServiceFfromURIMap(AxisService service) {
            eprToServiceNameMap.remove(serviceNameToEPRMap.get(service.getName()));
            serviceNameToEPRMap.remove(service.getName());
        }

        private boolean isServiceWithCustomURI(String serviceName){

            if(serviceNameToEPRMap.containsKey(serviceName)){
                return true;
            }
            //if map is not containing service name and there is no dot in service name
            //service is not have a custom URI
            if(!serviceName.contains(".")){
                return false;
            }
            serviceName = serviceName.substring(0,serviceName.lastIndexOf("."));
            return isServiceWithCustomURI(serviceName);
        }

        /** Only call this service IFF isServiceWithCustomURI(serviceName) is true
         * Else some nasty things can happen
         * @param serviceName
         * @return serviceName without endpoint part
         */
        private String getServiceNameFromServiceWithCustomURI(String serviceName){

            if(serviceNameToEPRMap.containsKey(serviceName)){
                return serviceName;
            }
            serviceName = serviceName.substring(0,serviceName.lastIndexOf("."));
            return getServiceNameFromServiceWithCustomURI(serviceName);
        }

        public String getTransportName() {
            return pttInDescription.getName();
        }

        /**
         * Reload SSL configurations from configurations and reset all connections
         *
         * @param transportInDescription TransportInDescription of the configuration
         * @throws AxisFault
         */
        public void reloadDynamicSSLConfig(TransportInDescription transportInDescription)
                throws AxisFault {
            log.info("PassThroughHttpListener reloading SSL Config..");
            Parameter oldParameter = transportInDescription.getParameter("SSLProfiles");
            Parameter profilePathParam = transportInDescription.getParameter("dynamicSSLProfilesConfig");

            if (oldParameter != null && profilePathParam != null) {
                transportInDescription.removeParameter(oldParameter);
                this.reloadSpecificEndPoints(transportInDescription);
            }
        }

    }