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

java.lang.Object
  org.ow2.petals.component.framework.process.JBIAcceptorManager

public class JBIAcceptorManager
extends java.lang.Object

This class helps a Component to listen to MessageExchanges on the DeliveryChannel (accept() method). It starts or stops a pool of thread that listen to new incoming JBI from the bus. MessageExchanges

Since:

3.0

Author:

alouis - EBM Websourcing, ofabre - EBM Websourcing

Field Summary

protected AbstractComponent	component
protected JBIProcessorManager	jbiProcessorManager
protected java.util.logging.Logger	logger

Constructor Summary

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

Method Summary

void	start() Initialize and start threads which listen to MessageExchanges
void	stop() Stop threads that listen to MessageExchanges

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final java.util.logging.Logger logger

jbiProcessorManager

protected final JBIProcessorManager jbiProcessorManager

component

protected final AbstractComponent component

Constructor Detail

JBIAcceptorManager

public JBIAcceptorManager(AbstractComponent component,
                          JBIProcessorManager jbiProcessorManager,
                          RuntimeConfigurationNotifier runtimeConfiguration,
                          java.util.logging.Logger log)

Creates a new instance of JBIAcceptorManager

Parameters:

channel -

configuration - The configuration of component

componentName - Name of the component. Used to define the Thread name.

log -

suManager -

listener -

Method Detail

start

public void start()
           throws javax.jbi.JBIException

Initialize and start threads which listen to MessageExchanges

Throws:

javax.jbi.JBIException

stop

public void stop()

Stop threads that listen to MessageExchanges