public class StdioMessageReceiver extends AbstractPollingMessageReceiver
StdioMessageReceiver
is a listener for events from Mule components
which then simply passes the events on to the target components.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_BUFFER_SIZE |
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 |
---|
StdioMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
long checkFrequency) |
Modifier and Type | Method and Description |
---|---|
void |
doConnect() |
void |
doDisconnect() |
protected void |
doDispose() |
int |
getBufferSize() |
InputStream |
getInputStream() |
void |
poll() |
void |
setBufferSize(int bufferSize) |
void |
setInputStream(InputStream inputStream) |
createWork, doStart, doStop, getFrequency, getTimeUnit, schedule, 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 static final int DEFAULT_BUFFER_SIZE
public StdioMessageReceiver(Connector connector, Service service, InboundEndpoint endpoint, long checkFrequency) throws CreateException
CreateException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
public void doConnect() throws Exception
doConnect
in class AbstractMessageReceiver
Exception
public void doDisconnect() throws Exception
doDisconnect
in class AbstractMessageReceiver
Exception
public void poll()
poll
in class AbstractPollingMessageReceiver
public InputStream getInputStream()
public void setInputStream(InputStream inputStream)
public int getBufferSize()
public void setBufferSize(int bufferSize)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.