org.mule.providers.vm
Class VMMessageReceiver

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

public class VMMessageReceiver
extends TransactedPollingMessageReceiver

VMMessageReceiver is a listener of events from a mule component which then simply

passes the events on to the target component.

Version:
$Revision: 3798 $
Author:
Ross Mason, Guillaume Nodet

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
VMMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint)
           
 
Method Summary
 void doConnect()
           
 void doDisconnect()
           
protected  List getMessages()
           
 Object onCall(UMOEvent event)
           
 void onEvent(UMOEvent event)
           
protected  void processMessage(Object msg)
           
 
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

VMMessageReceiver

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

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

onEvent

public void onEvent(UMOEvent event)
             throws UMOException
Throws:
UMOException

onCall

public Object onCall(UMOEvent event)
              throws UMOException
Throws:
UMOException

getMessages

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

processMessage

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


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