|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.transport.AbstractConnector
org.mule.transport.stdio.StdioConnector
public abstract class StdioConnector
StdioConnector
can send and receive Mule events over IO streams.
Field Summary | |
---|---|
protected InputStream |
inputStream
|
protected OutputStream |
outputStream
|
static String |
STDIO
|
static String |
STREAM_SYSTEM_ERR
|
static String |
STREAM_SYSTEM_IN
|
static String |
STREAM_SYSTEM_OUT
|
Fields inherited from interface org.mule.api.transport.Connector |
---|
INT_VALUE_NOT_SET |
Fields inherited from interface org.mule.api.lifecycle.Disposable |
---|
PHASE_NAME |
Constructor Summary | |
---|---|
StdioConnector(MuleContext context)
|
Method Summary | |
---|---|
MessageReceiver |
createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Create a Message receiver for this connector |
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 |
void |
doStop()
Template method to perform any work when stopping the connectoe |
InputStream |
getInputStream()
|
OutputStream |
getOutputStream()
|
String |
getProtocol()
|
void |
registerListener(InboundEndpoint endpoint,
MessageProcessor listener,
FlowConstruct flowConstruct)
Registers a MessageProcessor listener which will listen to new message received from a specific transport channel and then processed by the endpoint. |
void |
setInputStream(InputStream inputStream)
|
void |
setOutputStream(OutputStream outputStream)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final String STDIO
public static final String STREAM_SYSTEM_IN
public static final String STREAM_SYSTEM_OUT
public static final String STREAM_SYSTEM_ERR
protected OutputStream outputStream
protected InputStream inputStream
Constructor Detail |
---|
public StdioConnector(MuleContext context)
Method Detail |
---|
public MessageReceiver createReceiver(FlowConstruct flowConstruct, InboundEndpoint endpoint) throws Exception
AbstractConnector
createReceiver
in class AbstractConnector
flowConstruct
- the service that will receive events from this receiver, the
listenerendpoint
- the endpoint that defies this inbound communication
TransportServiceDescriptor
initialised using the service and endpoint.
Exception
- if there is a problem creating the receiver. This exception
really depends on the underlying transport, thus any exception
could be thrownpublic void doStop()
AbstractConnector
doStop
in class AbstractConnector
protected void doDispose()
AbstractConnector
doDispose
in class AbstractConnector
public void doStart()
AbstractConnector
doStart
in class AbstractConnector
public String getProtocol()
public InputStream getInputStream()
public void setInputStream(InputStream inputStream)
public OutputStream getOutputStream()
public void setOutputStream(OutputStream outputStream)
public void registerListener(InboundEndpoint endpoint, MessageProcessor listener, FlowConstruct flowConstruct) throws Exception
Connector
registerListener
in interface Connector
registerListener
in class AbstractConnector
endpoint
- defines both the transport and channel/resource uri as well
the processing (transformation/filtering) that should occur when
the endpoint processes a new message from the transport receiver.listener
- the listener that will be invoked when messages are received
on the endpoint.flowConstruct
- reference to the flow construct that the listener is part
of for use as context for logging, notifications and error
handling.
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |