org.mule.transport.tcp
Class ExceptionReturnTcpMessageReceiver.TcpWorker
java.lang.Object
org.mule.transport.AbstractReceiverWorker
org.mule.transport.AbstractReceiverResourceWorker
org.mule.transport.tcp.TcpMessageReceiver.TcpWorker
org.mule.transport.tcp.ExceptionReturnTcpMessageReceiver.TcpWorker
- All Implemented Interfaces:
- Runnable, javax.resource.spi.work.Work, Disposable, Expirable
- Enclosing class:
- ExceptionReturnTcpMessageReceiver
protected class ExceptionReturnTcpMessageReceiver.TcpWorker
- extends TcpMessageReceiver.TcpWorker
Method Summary |
protected Object |
getNextMessage(Object resource)
The method used to read the next message from the underlying transport. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ExceptionReturnTcpMessageReceiver.TcpWorker
public ExceptionReturnTcpMessageReceiver.TcpWorker(Socket socket,
AbstractMessageReceiver receiver)
throws IOException
- Throws:
IOException
getNextMessage
protected Object getNextMessage(Object resource)
throws Exception
- Description copied from class:
AbstractReceiverResourceWorker
- The method used to read the next message from the underlying transport.
- Overrides:
getNextMessage
in class TcpMessageReceiver.TcpWorker
- Parameters:
resource
- the resource to read from, this may be a socket, a directory or some higher level
representation.
- Returns:
- the message read from the resource. This can be raw data such as a byte[].
- Throws:
Exception
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.