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 Summary

Fields

Modifier and Type	Field	Description
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
PullingListenerContainer()

Method Summary

Modifier and Type	Method	Description
void	configure()
void	decreaseThreadCount()
int	getCurrentThreadCount()
int	getMaxThreadCount()
void	increaseThreadCount()
boolean	isIdle()
boolean	isThreadCountControllable()
boolean	isThreadCountReadable()
void	setIdle(boolean b)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()