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
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
StdioMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
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, disableNativeScheduling, doStart, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, schedule, setFrequency, setTimeUnit, unschedule
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
public static final int DEFAULT_BUFFER_SIZE
public StdioMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint, long checkFrequency) throws CreateException
CreateException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
public void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
public void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
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–2015 MuleSoft, Inc.. All rights reserved.