org.mule.providers.stream
Class StreamConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.mule.providers.stream.StreamConnector
All Implemented Interfaces:
Disposable, java.beans.ExceptionListener, Initialisable, Startable, Stoppable, UMOConnector
Direct Known Subclasses:
SystemStreamConnector

public abstract class StreamConnector
extends AbstractServiceEnabledConnector

StreamConnector can send and receive mule events over IO streams.

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
StreamConnector()
           
 
Method Summary
 UMOMessageReceiver createReceiver(UMOComponent component, UMOEndpoint endpoint)
           
protected  void disposeConnector()
          Template method to perform any work when destroying the connectoe
 java.lang.String getId()
           
abstract  java.io.InputStream getInputStream()
           
abstract  java.io.OutputStream getOutputStream()
           
 java.lang.String getProtocol()
           
abstract  void reinitialise()
          Sub classes might want to reinitialise between stream reads here
 void run()
           
 void startConnector()
          Template method to perform any work when starting the connectoe
 void stopConnector()
          Template method to perform any work when stopping the connectoe
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
doInitialise, 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, registerListener, 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

StreamConnector

public StreamConnector()
Method Detail

createReceiver

public UMOMessageReceiver createReceiver(UMOComponent component,
                                         UMOEndpoint endpoint)
                                  throws java.lang.Exception
Overrides:
createReceiver in class AbstractServiceEnabledConnector
Throws:
java.lang.Exception

stopConnector

public void stopConnector()
Description copied from class: AbstractConnector
Template method to perform any work when stopping the connectoe

Overrides:
stopConnector in class AbstractConnector

disposeConnector

protected void disposeConnector()
                         throws UMOException
Description copied from class: AbstractConnector
Template method to perform any work when destroying the connectoe

Overrides:
disposeConnector in class AbstractConnector
Throws:
UMOException - if the method fails

startConnector

public void startConnector()
Description copied from class: AbstractConnector
Template method to perform any work when starting the connectoe

Overrides:
startConnector in class AbstractConnector

getProtocol

public java.lang.String getProtocol()
Specified by:
getProtocol in interface UMOConnector
Specified by:
getProtocol in class AbstractConnector

getInputStream

public abstract java.io.InputStream getInputStream()

getOutputStream

public abstract java.io.OutputStream getOutputStream()

reinitialise

public abstract void reinitialise()
Sub classes might want to reinitialise between stream reads here


getId

public java.lang.String getId()

run

public void run()


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.