public class VMMessageReceiver extends TransactedPollingMessageReceiver
VMMessageReceiver
is a listener for events from a Mule service which then simply passes
the events on to the target service.Modifier and Type | Class and Description |
---|---|
protected static class |
VMMessageReceiver.VMReceiverWorker |
TransactedPollingMessageReceiver.MessageProcessorWorker
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
connected, connecting, connectionStrategy, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
VMMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected PollingReceiverWorker |
createWork() |
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected MuleMessage |
getFirstMessage() |
protected List |
getFirstMessages() |
protected List |
getMessages()
It's impossible to process all messages in the receive transaction
|
Object |
onCall(MuleMessage message,
boolean synchronous) |
void |
onMessage(MuleMessage message) |
protected void |
processMessage(Object msg) |
protected void |
schedule()
This method registers this receiver for periodic polling ticks with the connectors
scheduler.
|
doStart, isReceiveMessagesInTransaction, isUseMultipleTransactedReceivers, poll, setReceiveMessagesInTransaction, setUseMultipleTransactedReceivers
doStop, getFrequency, getTimeUnit, setFrequency, setTimeUnit, unschedule
connect, disconnect, dispose, doInitialise, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, getEndpointURI, getListener, getReceiverKey, getService, getWorkManager, handleException, handleUnacceptedFilter, initialise, isConnected, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setConnector, setEndpoint, setExceptionDetails, setListener, setReceiverKey, setService, setWorkManager, start, stop, toString
public VMMessageReceiver(Connector connector, Service service, InboundEndpoint endpoint) throws CreateException
CreateException
protected void schedule() throws RejectedExecutionException, NullPointerException, IllegalArgumentException
AbstractPollingMessageReceiver
schedule
in class AbstractPollingMessageReceiver
RejectedExecutionException
NullPointerException
IllegalArgumentException
ScheduledExecutorService#scheduleWithFixedDelay(Runnable, long, long, TimeUnit)}
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void doConnect() throws Exception
doConnect
in class AbstractMessageReceiver
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractMessageReceiver
Exception
public void onMessage(MuleMessage message) throws MuleException
MuleException
public Object onCall(MuleMessage message, boolean synchronous) throws MuleException
MuleException
protected List getMessages() throws Exception
getMessages
in class TransactedPollingMessageReceiver
Exception
protected MuleMessage getFirstMessage() throws Exception
Exception
protected void processMessage(Object msg) throws Exception
processMessage
in class TransactedPollingMessageReceiver
Exception
protected PollingReceiverWorker createWork()
createWork
in class AbstractPollingMessageReceiver
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.