org.mule.transport.stdio
Class StdioConnector

java.lang.Object
  extended by org.mule.transport.AbstractConnector
      extended by 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.


Field Summary
protected  InputStream inputStream
           
protected  OutputStream outputStream
           
static String STDIO
           
static String STREAM_SYSTEM_ERR
           
static String STREAM_SYSTEM_IN
           
static String STREAM_SYSTEM_OUT
           
 
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
 
Fields inherited from interface org.mule.api.transport.Connector
INT_VALUE_NOT_SET
 
Fields inherited from interface org.mule.api.lifecycle.Initialisable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Startable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Stoppable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Disposable
PHASE_NAME
 
Constructor Summary
StdioConnector()
           
 
Method Summary
 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)
           
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

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
Constructor Detail

StdioConnector

public StdioConnector()
Method Detail

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 listener
endpoint - 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.