Class DynamicLoadbalanceEndpoint

    • Field Detail

      • sessionAffinity

        protected boolean sessionAffinity
        Flag to enable session affinity based load balancing.
      • dispatcher

        protected Dispatcher dispatcher
        Dispatcher used for session affinity.
      • sessionTimeout

        protected long sessionTimeout
    • Constructor Detail

      • DynamicLoadbalanceEndpoint

        public DynamicLoadbalanceEndpoint()
    • Method Detail

      • init

        public void init​(SynapseEnvironment synapseEnvironment)
        Description copied from interface: ManagedLifecycle
        This method should implement the initialization of the implemented parts of the configuration.
        Specified by:
        init in interface ManagedLifecycle
        Overrides:
        init in class LoadbalanceEndpoint
        Parameters:
        synapseEnvironment - SynapseEnvironment to be used for initialization
      • send

        public void send​(MessageContext synCtx)
        Description copied from interface: Endpoint
        Sends the message context according to an endpoint specific behavior.
        Specified by:
        send in interface Endpoint
        Overrides:
        send in class LoadbalanceEndpoint
        Parameters:
        synCtx - MessageContext to be sent.
      • setCookieHeader

        protected void setCookieHeader​(MessageContext synCtx)
      • setupTransportHeaders

        protected void setupTransportHeaders​(MessageContext synCtx)
        Adding the X-Forwarded-For/X-Originating-IP headers to the outgoing message.
        Parameters:
        synCtx - Current message context
      • setName

        public void setName​(String name)
        Description copied from interface: Nameable
        Set the name of an abstraction
        Specified by:
        setName in interface Nameable
        Overrides:
        setName in class AbstractEndpoint
        Parameters:
        name - String Representation of name
      • getDispatcher

        public Dispatcher getDispatcher()
      • setDispatcher

        public void setDispatcher​(Dispatcher dispatcher)
      • getSessionTimeout

        public long getSessionTimeout()
      • setSessionTimeout

        public void setSessionTimeout​(long sessionTimeout)
      • setSessionAffinity

        public void setSessionAffinity​(boolean sessionAffinity)
      • isSessionAffinityBasedLB

        public boolean isSessionAffinityBasedLB()