public abstract class StdioConnector extends AbstractConnector
StdioConnector
can send and receive Mule events over IO streams.Modifier and Type | Field and Description |
---|---|
protected InputStream |
inputStream |
protected OutputStream |
outputStream |
static String |
STDIO |
static String |
STREAM_SYSTEM_ERR |
static String |
STREAM_SYSTEM_IN |
static String |
STREAM_SYSTEM_OUT |
connected, connectedSemaphore, connecting, connectionStrategy, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
StdioConnector() |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
createReceiver(Service service,
InboundEndpoint endpoint)
Create a Message receiver for this connector
|
protected void |
doDispose()
Template method to perform any work when destroying the connectoe
|
void |
doStart()
Template method to perform any work when starting the connectoe
|
void |
doStop()
Template method to perform any work when stopping the connectoe
|
InputStream |
getInputStream() |
OutputStream |
getOutputStream() |
String |
getProtocol() |
void |
setInputStream(InputStream inputStream) |
void |
setOutputStream(OutputStream outputStream) |
checkDisposed, connect, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeRequesters, disposeWorkManagers, doConnect, doDisconnect, doInitialise, exceptionThrown, fireNotification, getConnectedSemaphore, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMessageAdapter, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isStarted, isSyncEnabled, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnectionStrategy, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, workAccepted, workCompleted, workRejected, workStarted
public static final String STDIO
public static final String STREAM_SYSTEM_IN
public static final String STREAM_SYSTEM_OUT
public static final String STREAM_SYSTEM_ERR
protected OutputStream outputStream
protected InputStream inputStream
public MessageReceiver createReceiver(Service service, InboundEndpoint endpoint) throws Exception
AbstractConnector
createReceiver
in class AbstractConnector
service
- the service that will receive events from this receiver,
the listenerendpoint
- the endpoint that defies this inbound communicationTransportServiceDescriptor
initialised using the service and endpoint.Exception
- if there is a problem creating the receiver. This exception
really depends on the underlying transport, thus any exception
could be thrownpublic void doStop()
AbstractConnector
doStop
in class AbstractConnector
protected void doDispose()
AbstractConnector
doDispose
in class AbstractConnector
public void doStart()
AbstractConnector
doStart
in class AbstractConnector
public String getProtocol()
public InputStream getInputStream()
public void setInputStream(InputStream inputStream)
public OutputStream getOutputStream()
public void setOutputStream(OutputStream outputStream)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.