org.mule.providers.jbi
Class JbiConnector

java.lang.Object
  org.mule.providers.AbstractConnector
      org.mule.providers.jbi.JbiConnector

All Implemented Interfaces:

javax.jbi.component.ComponentLifeCycle, Disposable, EventListener, ExceptionListener, Initialisable, UMOConnectable, UMOConnector, WorkListener

public class JbiConnector

extends AbstractConnector

implements javax.jbi.component.ComponentLifeCycle

JbiConnector can bind to a JBI container allowing components to send events via Mule.

Field Summary

Fields inherited from class org.mule.providers.AbstractConnector

connected, connecting, connectionStrategy, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, numberOfConcurrentTransactedReceivers, receivers, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect

Fields inherited from interface org.mule.umo.provider.UMOConnector

INT_VALUE_NOT_SET

Constructor Summary

JbiConnector()

Method Summary

protected void	doConnect() Template method where any connections should be made for the connector
protected void	doDisconnect() Template method where any connected resources used by the connector should be disconnected
protected void	doDispose() Template method to perform any work when destroying the connectoe
protected void	doInitialise()
protected void	doStart() Template method to perform any work when starting the connectoe
protected void	doStop() Template method to perform any work when stopping the connectoe
javax.jbi.component.ComponentContext	getComponentContext()
javax.jbi.messaging.DeliveryChannel	getDeliveryChannel()
javax.jbi.messaging.MessageExchangeFactory	getExchangeFactory()
javax.management.ObjectName	getExtensionMBeanName()
String	getProtocol()
void	init(javax.jbi.component.ComponentContext componentContext)
void	setExtensionMBeanName(javax.management.ObjectName extensionMBeanName)
void	shutDown()
void	start()
void	stop()

Methods inherited from class org.mule.providers.AbstractConnector

checkDisposed, connect, createReceiver, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeWorkManagers, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMessageAdapter, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getStreamMessageAdapter, getSupportedProtocols, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isStarted, lookupReceiver, receive, receive, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, send, setConnectionStrategy, setCreateMultipleTransactedReceivers, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setEnableMessageEvents, setExceptionListener, setMaxDispatchersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setServiceOverrides, setSessionHandler, setSupportedProtocols, startConnector, stopConnector, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, workAccepted, workCompleted, workRejected, workStarted

Methods inherited from class java.lang.Object

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

Constructor Detail

JbiConnector

public JbiConnector()

Method Detail

doInitialise

protected void doInitialise()
                     throws InitialisationException

Specified by:

doInitialise in class AbstractConnector

Throws:

InitialisationException

doDispose

protected void doDispose()

Description copied from class: AbstractConnector

Template method to perform any work when destroying the connectoe

Specified by:

doDispose in class AbstractConnector

doConnect

protected void doConnect()
                  throws Exception

Description copied from class: AbstractConnector

Template method where any connections should be made for the connector

Specified by:

doConnect in class AbstractConnector

Throws:

Exception

doDisconnect

protected void doDisconnect()
                     throws Exception

Description copied from class: AbstractConnector

Template method where any connected resources used by the connector should be disconnected

Specified by:

doDisconnect in class AbstractConnector

Throws:

Exception

doStart

protected void doStart()
                throws UMOException

Description copied from class: AbstractConnector

Template method to perform any work when starting the connectoe

Specified by:

doStart in class AbstractConnector

Throws:

UMOException - if the method fails

doStop

protected void doStop()
               throws UMOException

Description copied from class: AbstractConnector

Template method to perform any work when stopping the connectoe

Specified by:

doStop in class AbstractConnector

Throws:

UMOException - if the method fails

getProtocol

public String getProtocol()

Specified by:

getProtocol in interface UMOConnector

Returns:

the primary protocol name for endpoints of this connector

getExtensionMBeanName

public javax.management.ObjectName getExtensionMBeanName()

Specified by:

getExtensionMBeanName in interface javax.jbi.component.ComponentLifeCycle

setExtensionMBeanName

public void setExtensionMBeanName(javax.management.ObjectName extensionMBeanName)

getComponentContext

public javax.jbi.component.ComponentContext getComponentContext()

getDeliveryChannel

public javax.jbi.messaging.DeliveryChannel getDeliveryChannel()

getExchangeFactory

public javax.jbi.messaging.MessageExchangeFactory getExchangeFactory()

init

public void init(javax.jbi.component.ComponentContext componentContext)
          throws javax.jbi.JBIException

Specified by:

init in interface javax.jbi.component.ComponentLifeCycle

Throws:

javax.jbi.JBIException

See Also:

ComponentLifeCycle.init(ComponentContext)

start

public void start()

Specified by:

start in interface javax.jbi.component.ComponentLifeCycle

See Also:

ComponentLifeCycle.start()

stop

public void stop()

Specified by:

stop in interface javax.jbi.component.ComponentLifeCycle

See Also:

ComponentLifeCycle.stop()

shutDown

public void shutDown()
              throws javax.jbi.JBIException

Specified by:

shutDown in interface javax.jbi.component.ComponentLifeCycle

Throws:

javax.jbi.JBIException

See Also:

ComponentLifeCycle.shutDown()