org.mule.providers.jms
Class SingleJmsMessageReceiver
java.lang.Object
org.mule.providers.AbstractMessageReceiver
org.mule.providers.jms.SingleJmsMessageReceiver
- All Implemented Interfaces:
- Disposable, Lifecycle, Startable, Stoppable, UMOConnectable, UMOMessageReceiver
- Direct Known Subclasses:
- JmsMessageReceiver
- public class SingleJmsMessageReceiver
- extends AbstractMessageReceiver
Registers a single Jms MessageListener for an endpoint
| Methods inherited from class org.mule.providers.AbstractMessageReceiver |
applyResponseTransformer, connect, disconnect, dispose, doDispose, getComponent, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, getEndpointURI, getListener, getWorkManager, handleException, handleUnacceptedFilter, isConnected, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setExceptionDetails, setListener, setWorkManager, start, stop |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connector
protected JmsConnector connector
redeliveryHandler
protected RedeliveryHandler redeliveryHandler
consumer
protected MessageConsumer consumer
session
protected Session session
startOnConnect
protected boolean startOnConnect
SingleJmsMessageReceiver
public SingleJmsMessageReceiver(UMOConnector connector,
UMOComponent component,
UMOEndpoint endpoint)
throws InitialisationException
doConnect
public void doConnect()
throws Exception
- Specified by:
doConnect in class AbstractMessageReceiver
- Throws:
Exception
doDisconnect
public void doDisconnect()
throws Exception
- Specified by:
doDisconnect in class AbstractMessageReceiver
- Throws:
Exception
onMessage
public void onMessage(Message message)
doStart
public void doStart()
throws UMOException
- Overrides:
doStart in class AbstractMessageReceiver
- Throws:
UMOException
doStop
public void doStop()
throws UMOException
- Overrides:
doStop in class AbstractMessageReceiver
- Throws:
UMOException
closeConsumer
protected void closeConsumer()
createConsumer
protected void createConsumer()
throws Exception
- Create a consumer for the jms destination
- Throws:
Exception
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.