Class MediatorWorker

  • All Implemented Interfaces:
    Runnable

    public class MediatorWorker
    extends Object
    implements Runnable
    This class will be used as the executer for the injectAsync method for the sequence mediation
    • Constructor Detail

      • MediatorWorker

        public MediatorWorker​(Mediator seq,
                              MessageContext synCtx)
        Constructor of the MediatorWorker which sets the sequence and the message context
        Parameters:
        seq - - Sequence Mediator to be set
        synCtx - - Synapse MessageContext to be set
      • MediatorWorker

        public MediatorWorker​(MessageContext synCtx)
        Constructor od the MediatorWorker which sets the provided message context and the main sequence as the sequence for mediation
        Parameters:
        synCtx - - Synapse MessageContext to be set
    • Method Detail

      • run

        public void run()
        Execution method of the thread. This will just call the mediation of the specified Synapse MessageContext using the specified Sequence Mediator
        Specified by:
        run in interface Runnable
      • setStatisticsCloseEventListener

        public void setStatisticsCloseEventListener​(StatisticsCloseEventListener statisticsCloseEventListener)