Examples of updateSession()


Examples of org.apache.synapse.endpoints.SALoadbalanceEndpoint.updateSession()

                    // so update all session maps
                    List endpointList = (List) o;
                    Object e = endpointList.remove(0);
                    if (e != null && e instanceof SALoadbalanceEndpoint) {
                        SALoadbalanceEndpoint saLoadbalanceEndpoint = (SALoadbalanceEndpoint) e;
                        saLoadbalanceEndpoint.updateSession(synCtx, endpointList);
                    }
                }
            }
            synCtx.getEnvironment().send(null, synCtx);
View Full Code Here

Examples of org.apache.synapse.endpoints.SALoadbalanceEndpoint.updateSession()

                        // so update all session maps.
                        List endpointList = (List) o;
                        Object e = endpointList.remove(0);
                        if (e != null && e instanceof SALoadbalanceEndpoint) {
                            SALoadbalanceEndpoint saLoadbalanceEndpoint = (SALoadbalanceEndpoint) e;
                            saLoadbalanceEndpoint.updateSession(synCtx, endpointList);
                        }
                    }
                }
                synCtx.getEnvironment().send(null, synCtx);
View Full Code Here

Examples of org.apache.synapse.endpoints.SALoadbalanceEndpoint.updateSession()

                    // so update all session maps
                    List endpointList = (List) o;
                    Object e = endpointList.remove(0);
                    if (e != null && e instanceof SALoadbalanceEndpoint) {
                        SALoadbalanceEndpoint saLoadbalanceEndpoint = (SALoadbalanceEndpoint) e;
                        saLoadbalanceEndpoint.updateSession(synCtx, endpointList);
                    }
                }
            }
            synCtx.getEnvironment().send(null, synCtx);
View Full Code Here

Examples of org.apache.synapse.endpoints.SALoadbalanceEndpoint.updateSession()

                            if (name != null && name.equals(obj)) {
                                Endpoint rootEP = ((Endpoint) rootEPObj);

                                if (rootEP instanceof SALoadbalanceEndpoint) {
                                    SALoadbalanceEndpoint salEP = (SALoadbalanceEndpoint) rootEP;
                                    salEP.updateSession(synCtx, epNameList,
                                            isClusteringEnable);
                                }
                            }
                        }
View Full Code Here

Examples of org.apache.synapse.endpoints.SALoadbalanceEndpoint.updateSession()

                    Object e = epList.remove(0);

                    if (e != null) {
                        if (e instanceof SALoadbalanceEndpoint) {
                            SALoadbalanceEndpoint salEP = (SALoadbalanceEndpoint) e;
                            salEP.updateSession(synCtx, epList, isClusteringEnable);
                        }
                    }
                }
            }
View Full Code Here

Examples of org.apache.synapse.endpoints.dispatch.Dispatcher.updateSession()

            Dispatcher dispatcher =
                    (Dispatcher) synCtx.getProperty(
                            SynapseConstants.PROP_SAL_ENDPOINT_CURRENT_DISPATCHER);
            if (dispatcher != null) {
                if (!dispatcher.isServerInitiatedSession()) {
                    dispatcher.updateSession(synCtx);
                }
            }

            // This is only for stats collection
            synCtx.setProperty(SynapseConstants.SENDING_REQUEST, true);
View Full Code Here

Examples of org.apache.synapse.endpoints.dispatch.Dispatcher.updateSession()

            // If this response is related to session affinity endpoints -Server initiated session
            Dispatcher dispatcher =
                    (Dispatcher) synapseOutMsgCtx.getProperty(
                            SynapseConstants.PROP_SAL_ENDPOINT_CURRENT_DISPATCHER);
            if (dispatcher != null && dispatcher.isServerInitiatedSession()) {
                dispatcher.updateSession(synapseInMessageContext);
            }

            StatisticsReporter.reportForAllOnResponseReceived(synapseInMessageContext);
           
            // send the response message through the synapse mediation flow
View Full Code Here

Examples of org.apache.synapse.endpoints.dispatch.Dispatcher.updateSession()

            Dispatcher dispatcher =
                    (Dispatcher) synCtx.getProperty(
                            SynapseConstants.PROP_SAL_ENDPOINT_CURRENT_DISPATCHER);
            if (dispatcher != null) {
                if (!dispatcher.isServerInitiatedSession()) {
                    dispatcher.updateSession(synCtx);
                }
            }

            // This is only for stats collection
            synCtx.setProperty(SynapseConstants.SENDING_REQUEST, true);
View Full Code Here

Examples of org.apache.synapse.endpoints.dispatch.Dispatcher.updateSession()

            // If this response is related to session affinity endpoints -Server initiated session
            Dispatcher dispatcher =
                    (Dispatcher) synapseOutMsgCtx.getProperty(
                            SynapseConstants.PROP_SAL_ENDPOINT_CURRENT_DISPATCHER);
            if (dispatcher != null && dispatcher.isServerInitiatedSession()) {
                dispatcher.updateSession(synapseInMessageContext);
            }

            StatisticsReporter.reportForAllOnResponseReceived(synapseInMessageContext);
           
            // send the response message through the synapse mediation flow
View Full Code Here

Examples of org.apache.synapse.endpoints.dispatch.Dispatcher.updateSession()

            // If this response is related to session affinity endpoints -Server initiated session
            Dispatcher dispatcher =
                    (Dispatcher) synapseOutMsgCtx.getProperty(
                            SynapseConstants.PROP_SAL_ENDPOINT_CURRENT_DISPATCHER);
            if (dispatcher != null && dispatcher.isServerInitiatedSession()) {
                dispatcher.updateSession(synapseInMessageContext);
            }

            StatisticsReporter.reportForAllOnResponseReceived(synapseInMessageContext);
           
            // send the response message through the synapse mediation flow
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.