Class ParallelSenderExecutor

java.lang.Object
org.frankframework.core.AbstractRequestReplyExecutor
org.frankframework.senders.ParallelSenderExecutor
All Implemented Interfaces:
Runnable

public class ParallelSenderExecutor extends AbstractRequestReplyExecutor
  • Constructor Details

    • ParallelSenderExecutor

      public ParallelSenderExecutor(ISender sender, Message message, PipeLineSession session, io.micrometer.core.instrument.DistributionSummary summary)
  • Method Details

    • run

      public void run()
    • getSession

      public PipeLineSession getSession()
    • setThreadLimiter

      public void setThreadLimiter(ResourceLimiter threadLimiter)
    • setGuard

      public void setGuard(Phaser guard)
    • getDuration

      public long getDuration()