org.mule.transport.stdio
Class StdioConnector
java.lang.Object
org.mule.transport.AbstractConnector
org.mule.transport.stdio.StdioConnector
- All Implemented Interfaces:
- ExceptionListener, EventListener, javax.resource.spi.work.WorkListener, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, NamedObject, Connectable, Connector
- Direct Known Subclasses:
- PromptStdioConnector
public abstract class StdioConnector
- extends AbstractConnector
StdioConnector
can send and receive Mule events over IO streams.
Fields inherited from class org.mule.transport.AbstractConnector |
connected, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect |
Methods inherited from class org.mule.transport.AbstractConnector |
checkDisposed, connect, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeRequesters, disposeWorkManagers, doConnect, doDisconnect, doInitialise, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMessageAdapter, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isResponseEnabled, isStarted, isSyncEnabled, isValidateConnections, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnected, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted |
STDIO
public static final String STDIO
- See Also:
- Constant Field Values
STREAM_SYSTEM_IN
public static final String STREAM_SYSTEM_IN
- See Also:
- Constant Field Values
STREAM_SYSTEM_OUT
public static final String STREAM_SYSTEM_OUT
- See Also:
- Constant Field Values
STREAM_SYSTEM_ERR
public static final String STREAM_SYSTEM_ERR
- See Also:
- Constant Field Values
outputStream
protected OutputStream outputStream
inputStream
protected InputStream inputStream
StdioConnector
public StdioConnector()
createReceiver
public MessageReceiver createReceiver(Service service,
InboundEndpoint endpoint)
throws Exception
- Description copied from class:
AbstractConnector
- Create a Message receiver for this connector
- Overrides:
createReceiver
in class AbstractConnector
- Parameters:
service
- the service that will receive events from this receiver,
the listenerendpoint
- the endpoint that defies this inbound communication
- Returns:
- an instance of the message receiver defined in this connectors'
TransportServiceDescriptor
initialised using the service and endpoint.
- Throws:
Exception
- if there is a problem creating the receiver. This exception
really depends on the underlying transport, thus any exception
could be thrown
doStop
public void doStop()
- Description copied from class:
AbstractConnector
- Template method to perform any work when stopping the connectoe
- Specified by:
doStop
in class AbstractConnector
doDispose
protected void doDispose()
- Description copied from class:
AbstractConnector
- Template method to perform any work when destroying the connectoe
- Specified by:
doDispose
in class AbstractConnector
doStart
public void doStart()
- Description copied from class:
AbstractConnector
- Template method to perform any work when starting the connectoe
- Specified by:
doStart
in class AbstractConnector
getProtocol
public String getProtocol()
- Returns:
- the primary protocol name for endpoints of this connector
getInputStream
public InputStream getInputStream()
setInputStream
public void setInputStream(InputStream inputStream)
getOutputStream
public OutputStream getOutputStream()
setOutputStream
public void setOutputStream(OutputStream outputStream)
Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.