org.mule.providers.stream
Class SystemStreamConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.mule.providers.stream.StreamConnector
              extended byorg.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.


Field Summary
 
Fields inherited from class org.mule.providers.stream.StreamConnector
inputStream, outputStream, STREAM_SYSTEM_ERR, STREAM_SYSTEM_IN, STREAM_SYSTEM_OUT
 
Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector
serviceDescriptor, serviceOverrides
 
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
 
Fields inherited from interface org.mule.umo.provider.UMOConnector
INT_VALUE_NOT_SET
 
Constructor Summary
SystemStreamConnector()
           
 
Method Summary
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
 UMOConnector getConnector()
           
 Object getDelegateSession()
           
 InputStream getInputStream()
           
 long getMessageDelayTime()
           
 String getOutputMessage()
           
 OutputStream getOutputStream()
           
 String getPromptMessage()
           
 UMOMessageReceiver registerListener(UMOComponent component, UMOEndpoint endpoint)
          This creates a UMOMessageReceiver associated with this endpoint and registers it with the connector
 void setMessageDelayTime(long messageDelayTime)
           
 void setOutputMessage(String outputMessage)
           
 void setPromptMessage(String promptMessage)
           
 
Methods inherited from class org.mule.providers.stream.StreamConnector
createReceiver, doStop, getProtocol, setInputStream, setOutputStream
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
doInitialise, getMessageAdapter, getServiceDescriptor, getServiceOverrides, getStreamMessageAdapter, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides
 
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
 

Constructor Detail

SystemStreamConnector

public SystemStreamConnector()
Method Detail

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.