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, java.beans.ExceptionListener, Initialisable, Startable, Stoppable, UMOConnector

public class SystemStreamConnector
extends StreamConnector

SystemStreamConnector TODO

Version:
$Revision: 1.1.1.1 $
Author:
Ross Mason

Field Summary
 
Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector
serviceDescriptor, serviceOverrides
 
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
 
Constructor Summary
SystemStreamConnector()
           
 
Method Summary
 void doInitialise()
           
 UMOConnector getConnector()
           
 java.lang.Object getDelegateSession()
           
 java.io.InputStream getInputStream()
           
 long getMessageDelayTime()
           
 java.io.OutputStream getOutputStream()
           
 java.lang.String getPromptMessage()
           
 UMOMessageReceiver registerListener(UMOComponent component, UMOEndpoint endpoint)
          This creates a UMOMessageReceiver associated with this endpoint and registers it with the endpoint
 void reinitialise()
          Sub classes might want to reinitialise between stream reads here
 void setMessageDelayTime(long messageDelayTime)
           
 void setPromptMessage(java.lang.String promptMessage)
           
 void startConnector()
          Template method to perform any work when starting the connectoe
 
Methods inherited from class org.mule.providers.stream.StreamConnector
createReceiver, disposeConnector, getId, getProtocol, run, stopConnector
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
getMessageAdapter, getServiceDescriptor, getServiceOverrides, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides
 
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
 

Constructor Detail

SystemStreamConnector

public SystemStreamConnector()
Method Detail

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.