Package org.frankframework.receivers

Class PullingListenerContainer<M>

java.lang.Object
org.frankframework.receivers.PullingListenerContainer<M>
All Implemented Interfaces:
IThreadCountControllable
public class PullingListenerContainer<M> extends Object implements IThreadCountControllable
Container that provides threads to execute pulling listeners.
Since:
4.8
Author:
Tim van der Leeuw

  • Field Details

    • log

      protected org.apache.logging.log4j.Logger log

  • Constructor Details

    • PullingListenerContainer

      public PullingListenerContainer()

  • Method Details

    • configure

      public void configure()

    • start

      public void start()

    • stop

      public void stop()

    • isThreadCountReadable

      public boolean isThreadCountReadable()
      Specified by:
      isThreadCountReadable in interface IThreadCountControllable

    • isThreadCountControllable

      public boolean isThreadCountControllable()
      Specified by:
      isThreadCountControllable in interface IThreadCountControllable

    • getCurrentThreadCount

      public int getCurrentThreadCount()
      Specified by:
      getCurrentThreadCount in interface IThreadCountControllable

    • getMaxThreadCount

      public int getMaxThreadCount()
      Specified by:
      getMaxThreadCount in interface IThreadCountControllable

    • increaseThreadCount

      public void increaseThreadCount()
      Specified by:
      increaseThreadCount in interface IThreadCountControllable

    • decreaseThreadCount

      public void decreaseThreadCount()
      Specified by:
      decreaseThreadCount in interface IThreadCountControllable

    • setIdle

      public void setIdle(boolean b)

    • isIdle

      public boolean isIdle()

    • setMetricsInitializer

      public void setMetricsInitializer(MetricsInitializer metricsInitializer)

    • getReceiver

      public Receiver<M> getReceiver()

    • setReceiver

      public void setReceiver(Receiver<M> receiver)

    • getTxManager

      public org.springframework.transaction.PlatformTransactionManager getTxManager()

    • setTxManager

      public void setTxManager(org.springframework.transaction.PlatformTransactionManager txManager)

    • getTaskExecutor

      public org.springframework.core.task.TaskExecutor getTaskExecutor()
      The thread-pool for spawning threads, injected by Spring

    • setTaskExecutor

      public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
      The thread-pool for spawning threads, injected by Spring