org.mule.transport.tcp
Class ExceptionReturnTcpMessageReceiver
java.lang.Object
org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageReceiver
org.mule.transport.tcp.TcpMessageReceiver
org.mule.transport.tcp.ExceptionReturnTcpMessageReceiver
- All Implemented Interfaces:
- Runnable, javax.resource.spi.work.Work, Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, MessageSource, Connectable, MessageReceiver
public class ExceptionReturnTcpMessageReceiver
- extends TcpMessageReceiver
Extends TcpMessageReceiver
providing managing of protocol error conditions.
ExceptionReturnTcpMessageReceiver.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.
Methods inherited from class org.mule.transport.AbstractMessageReceiver |
applyInboundTransformers, applyResponseTransformers, createExecutionTemplate, createLifecycleManager, createMuleEvent, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, propagateRootMessageIdProperty, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, toString, warnIfMuleClientSendUsed |
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
ExceptionReturnTcpMessageReceiver
public ExceptionReturnTcpMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
throws CreateException
- Throws:
CreateException
createWork
protected javax.resource.spi.work.Work createWork(Socket socket)
throws IOException
- Overrides:
createWork
in class TcpMessageReceiver
- Throws:
IOException
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.