org.mule.providers.jms
Class JmsMessageReceiver
java.lang.Object
org.mule.providers.AbstractMessageReceiver
org.mule.providers.PollingMessageReceiver
org.mule.providers.TransactedPollingMessageReceiver
org.mule.providers.jms.JmsMessageReceiver
- All Implemented Interfaces:
- Disposable, UMOMessageReceiver
- public class JmsMessageReceiver
- extends TransactedPollingMessageReceiver
- Version:
- $Revision: 1.11 $
- Author:
- Ross Mason, Guillaume Nodet
Methods inherited from class org.mule.providers.AbstractMessageReceiver |
allowFilter, create, dispose, getComponent, getConnector, getEndpoint, getEndpointURI, getWorkManager, handleException, handleUnacceptedFilter, isServerSide, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setServerSide, setWorkManager |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connector
protected JmsConnector connector
reuseConsumer
protected boolean reuseConsumer
reuseSession
protected boolean reuseSession
session
protected Session session
consumer
protected MessageConsumer consumer
frequency
protected long frequency
redeliveryHandler
protected RedeliveryHandler redeliveryHandler
JmsMessageReceiver
public JmsMessageReceiver()
JmsMessageReceiver
public JmsMessageReceiver(UMOConnector connector,
UMOComponent component,
UMOEndpoint endpoint)
throws InitialisationException
poll
public void poll()
throws java.lang.Exception
- The poll method is overrident from the
- Overrides:
poll
in class TransactedPollingMessageReceiver
- Throws:
java.lang.Exception
getMessages
protected java.util.List getMessages()
throws java.lang.Exception
- Specified by:
getMessages
in class TransactedPollingMessageReceiver
- Throws:
java.lang.Exception
processMessage
protected void processMessage(java.lang.Object msg)
throws java.lang.Exception
- Specified by:
processMessage
in class TransactedPollingMessageReceiver
- Throws:
java.lang.Exception
closeConsumer
protected void closeConsumer()
createConsumer
protected void createConsumer()
throws java.lang.Exception
- Create a consumer for the jms destination
- Throws:
java.lang.Exception
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.