org.ow2.petals.component.framework.process
Class JBIProcessorManager

java.lang.Object
  org.ow2.petals.component.framework.process.JBIProcessorManagerObservable
      org.ow2.petals.component.framework.process.JBIProcessorManager

public class JBIProcessorManager
extends JBIProcessorManagerObservable

The JBI processor manager is in charge of JBI Message processor threads and instances.

Since:

3.0

Author:

chamerling - EBM WebSourcing

Field Summary

protected AbstractComponent	component
protected java.util.logging.Logger	logger
protected org.apache.commons.pool.impl.GenericObjectPool	objectPool

Constructor Summary

JBIProcessorManager(AbstractComponent component, RuntimeConfigurationNotifier runtimeConfiguration, java.util.logging.Logger logger)
Creates a new instance of JBIProcessorManager

Method Summary

org.apache.commons.pool.impl.GenericObjectPool	getObjectPool() Get the Processor Object Pool.
java.util.concurrent.ThreadPoolExecutor	getThreadPool() Get the Processor Thread Pool.
void	start() Start the Processor Thread Pool.
void	stop() Stop the Processor Thread Pool.

Methods inherited from class org.ow2.petals.component.framework.process.JBIProcessorManagerObservable

addObserver, deleteObserver, notifyObserversAfterProcessing, notifyObserversBeforeProcessing

Methods inherited from class java.lang.Object

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

Field Detail

objectPool

protected org.apache.commons.pool.impl.GenericObjectPool objectPool

component

protected AbstractComponent component

logger

protected java.util.logging.Logger logger

Constructor Detail

JBIProcessorManager

public JBIProcessorManager(AbstractComponent component,
                           RuntimeConfigurationNotifier runtimeConfiguration,
                           java.util.logging.Logger logger)

Creates a new instance of JBIProcessorManager

Parameters:

component -

configuration -

logger -

Method Detail

start

public void start()
           throws javax.jbi.JBIException

Start the Processor Thread Pool.

Throws:

javax.jbi.JBIException

stop

public void stop()

Stop the Processor Thread Pool.

getThreadPool

public java.util.concurrent.ThreadPoolExecutor getThreadPool()

Get the Processor Thread Pool.

getObjectPool

public org.apache.commons.pool.impl.GenericObjectPool getObjectPool()

Get the Processor Object Pool.