org.mule.providers.stream
Class StreamConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.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
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, 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 |
StreamConnector
public StreamConnector()
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.