org.mule.providers.space
Class TransactedSpaceMessageReceiver

java.lang.Object
  extended byorg.mule.providers.AbstractMessageReceiver
      extended byorg.mule.providers.PollingMessageReceiver
          extended byorg.mule.providers.TransactedPollingMessageReceiver
              extended byorg.mule.providers.space.TransactedSpaceMessageReceiver
All Implemented Interfaces:
Disposable, Lifecycle, Startable, Stoppable, UMOConnectable, UMOMessageReceiver

public class TransactedSpaceMessageReceiver
extends TransactedPollingMessageReceiver

Registers a transacted message listener on a Space.


Nested Class Summary
 
Nested classes inherited from class org.mule.providers.TransactedPollingMessageReceiver
TransactedPollingMessageReceiver.MessageProcessorWorker
 
Field Summary
 
Fields inherited from class org.mule.providers.TransactedPollingMessageReceiver
receiveMessagesInTransaction, useMultipleReceivers
 
Fields inherited from class org.mule.providers.PollingMessageReceiver
DEFAULT_POLL_FREQUENCY, frequency, STARTUP_DELAY
 
Fields inherited from class org.mule.providers.AbstractMessageReceiver
component, connected, connectionStrategy, disposing, endpoint, logger, stopped
 
Constructor Summary
TransactedSpaceMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint)
           
 
Method Summary
 void doConnect()
           
 void doDisconnect()
           
protected  List getMessages()
           
 UMOSpace getSpace()
           
protected  void processMessage(Object message)
           
 
Methods inherited from class org.mule.providers.TransactedPollingMessageReceiver
doStart, poll
 
Methods inherited from class org.mule.providers.PollingMessageReceiver
getFrequency, release, run, setFrequency
 
Methods inherited from class org.mule.providers.AbstractMessageReceiver
applyResponseTransformer, connect, disconnect, dispose, doDispose, doStop, 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
 

Constructor Detail

TransactedSpaceMessageReceiver

public TransactedSpaceMessageReceiver(UMOConnector connector,
                                      UMOComponent component,
                                      UMOEndpoint endpoint)
                               throws InitialisationException
Method Detail

getMessages

protected List getMessages()
                    throws Exception
Specified by:
getMessages in class TransactedPollingMessageReceiver
Throws:
Exception

processMessage

protected void processMessage(Object message)
                       throws Exception
Specified by:
processMessage in class TransactedPollingMessageReceiver
Throws:
Exception

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

getSpace

public UMOSpace getSpace()


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