|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.providers.AbstractMessageReceiver
AbstractMessageReceiver
provides common methods for all Message Receivers provided with Mule.
A message receiver enables an endpoint to receive a message from an external system.
Field Summary | |
protected UMOComponent |
component
The Component with which this receiver is associated with |
protected UMOConnector |
connector
the endpoint to receive events on |
protected SynchronizedBoolean |
disposing
|
protected UMOEndpoint |
endpoint
The endpoint descriptor which is associated with this receiver |
protected Log |
logger
logger used by this class |
protected UMOModel |
model
The model managing the UMO components |
protected boolean |
serverSide
|
Constructor Summary | |
AbstractMessageReceiver()
|
Method Summary | |
protected boolean |
allowFilter(UMOFilter filter)
|
void |
create(UMOConnector connector,
UMOComponent component,
UMOEndpoint endpoint)
Creates the Message Receiver |
void |
dispose()
A lifecycle method where implementor should fee up any resources If an exception is thrown it should just be logged and processing should continue. |
protected void |
doDispose()
Template method to dispose any resources associated with this receiver. |
UMOComponent |
getComponent()
|
UMOConnector |
getConnector()
|
UMOEndpoint |
getEndpoint()
|
UMOEndpointURI |
getEndpointURI()
The endpointUri that this receiver listens on |
protected UMOWorkManager |
getWorkManager()
|
void |
handleException(java.lang.Exception exception)
|
protected UMOMessage |
handleUnacceptedFilter(UMOMessage message)
|
boolean |
isServerSide()
|
UMOMessage |
routeMessage(UMOMessage message)
|
UMOMessage |
routeMessage(UMOMessage message,
boolean synchronous)
|
UMOMessage |
routeMessage(UMOMessage message,
boolean synchronous,
java.io.OutputStream outputStream)
|
UMOMessage |
routeMessage(UMOMessage message,
java.io.OutputStream outputStream)
|
UMOMessage |
routeMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous)
|
UMOMessage |
routeMessage(UMOMessage message,
UMOTransaction trans,
boolean synchronous,
java.io.OutputStream outputStream)
|
void |
setComponent(UMOComponent component)
|
void |
setConnector(UMOConnector connector)
|
void |
setEndpoint(UMOEndpoint endpoint)
|
void |
setServerSide(boolean serverSide)
|
protected void |
setWorkManager(UMOWorkManager workManager)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected transient Log logger
protected UMOComponent component
protected UMOEndpoint endpoint
protected UMOModel model
protected UMOConnector connector
protected boolean serverSide
protected SynchronizedBoolean disposing
Constructor Detail |
public AbstractMessageReceiver()
Method Detail |
public void create(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint) throws InitialisationException
UMOMessageReceiver
create
in interface UMOMessageReceiver
connector
- the endpoint that created this listenercomponent
- the component to associate with the receiver. When data is recieved the component
dispatchEvent
or sendEvent
is used to dispatch the data to the relivant UMO.endpoint
- the proivder contains the endpointUri on which the
receiver will listen on. The endpointUri can be anything and is specific to
the receiver implementation i.e. an email address, a directory, a jms destination
or port address.
InitialisationException
UMOComponent
,
UMOEndpoint
public UMOEndpoint getEndpoint()
getEndpoint
in interface UMOMessageReceiver
public void handleException(java.lang.Exception exception)
public UMOConnector getConnector()
getConnector
in interface UMOMessageReceiver
public void setConnector(UMOConnector connector)
setConnector
in interface UMOMessageReceiver
public UMOComponent getComponent()
getComponent
in interface UMOMessageReceiver
public final UMOMessage routeMessage(UMOMessage message) throws UMOException
UMOException
public final UMOMessage routeMessage(UMOMessage message, boolean synchronous) throws UMOException
UMOException
public final UMOMessage routeMessage(UMOMessage message, UMOTransaction trans, boolean synchronous) throws UMOException
UMOException
public final UMOMessage routeMessage(UMOMessage message, java.io.OutputStream outputStream) throws UMOException
UMOException
public final UMOMessage routeMessage(UMOMessage message, boolean synchronous, java.io.OutputStream outputStream) throws UMOException
UMOException
public final UMOMessage routeMessage(UMOMessage message, UMOTransaction trans, boolean synchronous, java.io.OutputStream outputStream) throws UMOException
UMOException
protected UMOMessage handleUnacceptedFilter(UMOMessage message)
public void setEndpoint(UMOEndpoint endpoint)
setEndpoint
in interface UMOMessageReceiver
endpoint
- the endpoint to listen onUMOEndpoint
public void setComponent(UMOComponent component)
setComponent
in interface UMOMessageReceiver
component
- the component to associate with the receiver. When data is recieved the component
dispatchEvent
or sendEvent
is used to dispatch the data to the relivant UMO.public final void dispose()
Disposable
dispose
in interface Disposable
protected void doDispose()
public UMOEndpointURI getEndpointURI()
UMOMessageReceiver
getEndpointURI
in interface UMOMessageReceiver
protected boolean allowFilter(UMOFilter filter) throws java.lang.UnsupportedOperationException
java.lang.UnsupportedOperationException
public boolean isServerSide()
public void setServerSide(boolean serverSide)
protected UMOWorkManager getWorkManager()
protected void setWorkManager(UMOWorkManager workManager)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |