public class TcpMessageReceiver extends AbstractMessageReceiver implements javax.resource.spi.work.Work
TcpMessageReceiver
acts like a TCP server to receive socket
requests.Modifier and Type | Class and Description |
---|---|
protected class |
TcpMessageReceiver.TcpWorker |
Modifier and Type | Field and Description |
---|---|
protected AtomicBoolean |
disposing |
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
TcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected javax.resource.spi.work.Work |
createWork(Socket socket) |
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected void |
doStart() |
protected void |
doStop() |
ServerSocket |
getServerSocket()
Obtain the serverSocket
|
void |
release() |
void |
run() |
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
protected final AtomicBoolean disposing
public TcpMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected void doConnect() throws ConnectException
doConnect
in class AbstractTransportMessageHandler
ConnectException
protected void doDisconnect() throws ConnectException
doDisconnect
in class AbstractTransportMessageHandler
ConnectException
protected void doStart() throws MuleException
doStart
in class AbstractTransportMessageHandler
MuleException
protected void doStop() throws MuleException
doStop
in class AbstractMessageReceiver
MuleException
public ServerSocket getServerSocket()
public void release()
release
in interface javax.resource.spi.work.Work
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected javax.resource.spi.work.Work createWork(Socket socket) throws IOException
IOException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.