public class ExceptionReturnTcpMessageReceiver extends TcpMessageReceiver
TcpMessageReceiver
providing managing of protocol error conditions.
TcpMessageReceiver.TcpWorker.getNextMessage(Object)
is extended so, in case
of an protocol error it will try to send the exception back to the client instead
of ignoring it. If an exception is thrown managing the error it will ignored.Modifier and Type | Class and Description |
---|---|
protected class |
ExceptionReturnTcpMessageReceiver.TcpWorker |
disposing
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
ExceptionReturnTcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected javax.resource.spi.work.Work |
createWork(Socket socket) |
doConnect, doDisconnect, doDispose, doStart, doStop, getServerSocket, release, 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
public ExceptionReturnTcpMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected javax.resource.spi.work.Work createWork(Socket socket) throws IOException
createWork
in class TcpMessageReceiver
IOException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.