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, java.beans.ExceptionListener, Initialisable, Startable, Stoppable, UMOConnector
- public class SystemStreamConnector
- extends StreamConnector
SystemStreamConnector
TODO
- Version:
- $Revision: 1.1.1.1 $
- Author:
- Ross Mason
Fields inherited from class org.mule.providers.AbstractConnector |
DEFAULT_RETRY_COUNT, DEFAULT_RETRY_FREQUENCY, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, exceptionStrategy, initialised, name, receivers, started |
Methods inherited from class org.mule.providers.AbstractConnector |
createDispatcher, destroyReceiver, dispose, exceptionThrown, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcherFactory, getDispatcherThreadingProfile, getExceptionStrategy, getName, getReceiverKey, getReceiverThreadingProfile, getReplyToHandler, getRetryCount, getRetryFrequency, handleException, initialise, isDisposed, isDisposeDispatcherOnCompletion, isStarted, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setDisposeDispatcherOnCompletion, setExceptionStrategy, setName, setReceiverThreadingProfile, setRetryCount, setRetryFrequency, start, stop, unregisterListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SystemStreamConnector
public SystemStreamConnector()
doInitialise
public void doInitialise()
throws InitialisationException
- Overrides:
doInitialise
in class AbstractServiceEnabledConnector
- Throws:
InitialisationException
getInputStream
public java.io.InputStream getInputStream()
- Specified by:
getInputStream
in class StreamConnector
startConnector
public void startConnector()
- Description copied from class:
AbstractConnector
- Template method to perform any work when starting the connectoe
- Overrides:
startConnector
in class StreamConnector
getOutputStream
public java.io.OutputStream getOutputStream()
- Specified by:
getOutputStream
in class StreamConnector
reinitialise
public void reinitialise()
- Description copied from class:
StreamConnector
- Sub classes might want to reinitialise between stream reads here
- Specified by:
reinitialise
in class StreamConnector
getPromptMessage
public java.lang.String getPromptMessage()
- Returns:
- Returns the promptMessage.
setPromptMessage
public void setPromptMessage(java.lang.String promptMessage)
- Parameters:
promptMessage
- The promptMessage to set.
getConnector
public UMOConnector getConnector()
getDelegateSession
public java.lang.Object getDelegateSession()
throws UMOException
- Throws:
UMOException
registerListener
public UMOMessageReceiver registerListener(UMOComponent component,
UMOEndpoint endpoint)
throws java.lang.Exception
- Description copied from interface:
UMOConnector
- This creates a
UMOMessageReceiver
associated with this endpoint and registers it
with the endpoint
- Specified by:
registerListener
in interface UMOConnector
- Overrides:
registerListener
in class AbstractConnector
- Throws:
java.lang.Exception
getMessageDelayTime
public long getMessageDelayTime()
- Returns:
- Returns the messageDelayTime.
setMessageDelayTime
public void setMessageDelayTime(long messageDelayTime)
- Parameters:
messageDelayTime
- The messageDelayTime to set.
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.