org.mule.providers.stream
Class SystemStreamConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.mule.providers.stream.StreamConnector
org.mule.providers.stream.SystemStreamConnector
- All Implemented Interfaces:
- Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector
- public class SystemStreamConnector
- extends StreamConnector
SystemStreamConnector connects to the System streams in and out by
default and add some basic fuctionality for writing out prompt messages.
| Fields inherited from class org.mule.providers.AbstractConnector |
connected, connecting, createDispatcherPerRequest, createMultipleTransactedReceivers, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, receivers, serverSide, sessionHandler, started, startOnConnect |
| Methods inherited from class org.mule.providers.AbstractConnector |
checkDisposed, connect, createDispatcher, destroyReceiver, disconnect, dispose, disposeDispatchers, disposeReceivers, doConnect, doDisconnect, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiver, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReplyToHandler, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initialise, isConnected, isCreateDispatcherPerRequest, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isServerSide, isStarted, isUseSingleDispatcherThreadPool, isUseSingleReceiverThreadPool, lookupDispatcher, lookupReceiver, registerSupportedProtocol, registerSupportedProtocolWithotPrefix, setConnectionStrategy, setCreateDispatcherPerRequest, setCreateMultipleTransactedReceivers, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setEnableMessageEvents, setExceptionListener, setName, setReceiverThreadingProfile, setServerSide, setSessionHandler, setSupportedProtocols, setUseSingleDispatcherThreadPool, setUseSingleReceiverThreadPool, startConnector, stopConnector, supportsProtocol, unregisterListener, unregisterSupportedProtocol, workAccepted, workCompleted, workRejected, workStarted |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SystemStreamConnector
public SystemStreamConnector()
getInputStream
public InputStream getInputStream()
- Overrides:
getInputStream in class StreamConnector
doStart
public void doStart()
- Description copied from class:
AbstractConnector
- Template method to perform any work when starting the connectoe
- Overrides:
doStart in class StreamConnector
getOutputStream
public OutputStream getOutputStream()
- Overrides:
getOutputStream in class StreamConnector
getPromptMessage
public String getPromptMessage()
- Returns:
- Returns the promptMessage.
setPromptMessage
public void setPromptMessage(String promptMessage)
- Parameters:
promptMessage - The promptMessage to set.
getOutputMessage
public String getOutputMessage()
- Returns:
- Returns the outputMessage.
setOutputMessage
public void setOutputMessage(String outputMessage)
- Parameters:
outputMessage - The outputMessage to set.
getConnector
public UMOConnector getConnector()
getDelegateSession
public Object getDelegateSession()
throws UMOException
- Throws:
UMOException
registerListener
public UMOMessageReceiver registerListener(UMOComponent component,
UMOEndpoint endpoint)
throws Exception
- Description copied from interface:
UMOConnector
- This creates a
UMOMessageReceiver associated with this endpoint
and registers it with the connector
- Specified by:
registerListener in interface UMOConnector- Overrides:
registerListener in class AbstractConnector
- Throws:
Exception
getMessageDelayTime
public long getMessageDelayTime()
setMessageDelayTime
public void setMessageDelayTime(long messageDelayTime)
doDispose
protected void doDispose()
- Description copied from class:
AbstractConnector
- Template method to perform any work when destroying the connectoe
- Overrides:
doDispose in class StreamConnector
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.