org.mule.providers.jbi.components
Class AbstractJbiComponent

java.lang.Object
  extended byorg.mule.providers.jbi.components.AbstractJbiComponent
Direct Known Subclasses:
AbstractEndpointComponent, TransformerComponent

public abstract class AbstractJbiComponent
extends Object

A base Jbi component implementation. This is agnostic to any particular Jbi container

Version:
$Revision: 3798 $
Author:
Ross Mason

Nested Class Summary
protected  class AbstractJbiComponent.MessageExchangeWorker
           
 
Field Summary
protected  ComponentContext context
           
protected  DeliveryChannel deliveryChannel
           
protected  MessageExchangeFactory exchangeFactory
           
static String IN
           
protected  Log logger
          logger used by this class
protected  ObjectName mbeanName
           
protected  String name
           
static String OUT
           
protected  QName service
           
protected  Map serviceDescriptions
           
protected  ServiceUnitManager serviceUnitManager
           
protected  WaitableBoolean started
           
protected  WorkManager workManager
           
 
Constructor Summary
AbstractJbiComponent()
           
 
Method Summary
protected  ObjectName createExtensionMBeanName()
           
protected  void doInit()
           
protected  void done(MessageExchange me)
           
protected  void doShutdown()
           
protected  void doStart()
           
protected  void doStop()
           
protected  void error(MessageExchange me, Fault fault)
           
 Object getExtensionMBean()
           
 ObjectName getExtensionMBeanName()
           
 ComponentLifeCycle getLifeCycle()
           
 String getName()
           
 QName getService()
           
 Document getServiceDescription(ServiceEndpoint endpoint)
           
 ServiceUnitManager getServiceUnitManager()
           
 WorkManager getWorkManager()
           
protected  void handleException(Throwable t)
           
 void init(ComponentContext context)
           
 boolean isExchangeWithConsumerOkay(ServiceEndpoint endpoint, MessageExchange exchange)
           
 boolean isExchangeWithProviderOkay(ServiceEndpoint endpoint, MessageExchange exchange)
           
 void release()
           
 ServiceEndpoint resolveEndpointReference(DocumentFragment epr)
           
 void run()
           
 void setExtensionMBeanName(ObjectName mbeanName)
           
 void setName(String name)
           
 void setService(QName service)
           
 void setServiceDescription(ServiceEndpoint endpoint, Document doc)
           
 void setWorkManager(WorkManager workManager)
           
 void shutDown()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

IN

public static final String IN
See Also:
Constant Field Values

OUT

public static final String OUT
See Also:
Constant Field Values

logger

protected transient Log logger
logger used by this class


context

protected ComponentContext context

serviceDescriptions

protected Map serviceDescriptions

service

protected QName service

name

protected String name

workManager

protected WorkManager workManager

deliveryChannel

protected DeliveryChannel deliveryChannel

mbeanName

protected ObjectName mbeanName

serviceUnitManager

protected ServiceUnitManager serviceUnitManager

exchangeFactory

protected MessageExchangeFactory exchangeFactory

started

protected WaitableBoolean started
Constructor Detail

AbstractJbiComponent

public AbstractJbiComponent()
Method Detail

getLifeCycle

public ComponentLifeCycle getLifeCycle()

getServiceUnitManager

public ServiceUnitManager getServiceUnitManager()

getServiceDescription

public Document getServiceDescription(ServiceEndpoint endpoint)

setServiceDescription

public void setServiceDescription(ServiceEndpoint endpoint,
                                  Document doc)

isExchangeWithConsumerOkay

public boolean isExchangeWithConsumerOkay(ServiceEndpoint endpoint,
                                          MessageExchange exchange)

isExchangeWithProviderOkay

public boolean isExchangeWithProviderOkay(ServiceEndpoint endpoint,
                                          MessageExchange exchange)

resolveEndpointReference

public ServiceEndpoint resolveEndpointReference(DocumentFragment epr)

createExtensionMBeanName

protected ObjectName createExtensionMBeanName()
                                       throws Exception
Throws:
Exception

getExtensionMBean

public Object getExtensionMBean()

getService

public QName getService()

setService

public void setService(QName service)

getName

public String getName()

setName

public void setName(String name)

getWorkManager

public WorkManager getWorkManager()

setWorkManager

public void setWorkManager(WorkManager workManager)

init

public final void init(ComponentContext context)
                throws JBIException
Throws:
JBIException

shutDown

public final void shutDown()
                    throws JBIException
Throws:
JBIException

start

public final void start()
                 throws JBIException
Throws:
JBIException

stop

public final void stop()
                throws JBIException
Throws:
JBIException

doInit

protected void doInit()
               throws JBIException
Throws:
JBIException

doStart

protected void doStart()
                throws JBIException
Throws:
JBIException

doStop

protected void doStop()
               throws JBIException
Throws:
JBIException

doShutdown

protected void doShutdown()
                   throws JBIException
Throws:
JBIException

getExtensionMBeanName

public ObjectName getExtensionMBeanName()

setExtensionMBeanName

public void setExtensionMBeanName(ObjectName mbeanName)

release

public void release()

run

public void run()

handleException

protected void handleException(Throwable t)

error

protected void error(MessageExchange me,
                     Fault fault)
              throws MessagingException
Throws:
MessagingException

done

protected void done(MessageExchange me)
             throws MessagingException
Throws:
MessagingException


Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.