org.mule.transport.tcp
Class TcpMessageReceiver.TcpWorker
java.lang.Object
org.mule.transport.AbstractReceiverWorker
org.mule.transport.AbstractReceiverResourceWorker
org.mule.transport.tcp.TcpMessageReceiver.TcpWorker
- All Implemented Interfaces:
- Runnable, javax.resource.spi.work.Work, Disposable, Expirable
- Direct Known Subclasses:
- ExceptionReturnTcpMessageReceiver.TcpWorker, SslMessageReceiver.SslWorker
- Enclosing class:
- TcpMessageReceiver
protected class TcpMessageReceiver.TcpWorker
- extends AbstractReceiverResourceWorker
- implements Disposable, Expirable
Method Summary |
protected void |
bindTransaction(Transaction tx)
Template method used to bind the resources of this receiver to the transaction. |
void |
dispose()
A lifecycle method where implementor should free up any resources. |
void |
expired()
|
protected Object |
getNextMessage(Object resource)
The method used to read the next message from the underlying transport. |
protected void |
handleResults(List messages)
When Mule has finished processing the current messages, there may be zero or more messages to process
by the receiver if request/response messaging is being used. |
protected boolean |
hasMoreMessages(Object message)
|
protected void |
preRouteMuleMessage(MuleMessage message)
This callback is called before a message is routed into Mule and can be used by the worker to set connection
specific properties to message before it gets routed |
void |
release()
This method is called once this worker is no longer required. |
protected void |
shutdownSocket()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
socket
protected Socket socket
dataIn
protected TcpInputStream dataIn
underlyingIn
protected InputStream underlyingIn
dataOut
protected OutputStream dataOut
protocol
protected TcpProtocol protocol
dataInWorkFinished
protected boolean dataInWorkFinished
notify
protected Object notify
TcpMessageReceiver.TcpWorker
public TcpMessageReceiver.TcpWorker(Socket socket,
AbstractMessageReceiver receiver)
throws IOException
- Throws:
IOException
expired
public void expired()
- Specified by:
expired
in interface Expirable
dispose
public void dispose()
- Description copied from interface:
Disposable
- A lifecycle method where implementor should free up any resources. If an
exception is thrown it should just be logged and processing should continue.
This method should not throw Runtime exceptions.
- Specified by:
dispose
in interface Disposable
release
public void release()
- Description copied from class:
AbstractReceiverWorker
- This method is called once this worker is no longer required. Any resources *only* associated with
this worker should be cleaned up here.
- Specified by:
release
in interface javax.resource.spi.work.Work
- Overrides:
release
in class AbstractReceiverWorker
shutdownSocket
protected void shutdownSocket()
throws IOException
- Throws:
IOException
bindTransaction
protected void bindTransaction(Transaction tx)
throws TransactionException
- Description copied from class:
AbstractReceiverWorker
- Template method used to bind the resources of this receiver to the transaction. Only transactional
transports need implment this method
- Specified by:
bindTransaction
in class AbstractReceiverWorker
- Parameters:
tx
- the current transaction or null if there is no transaction
- Throws:
TransactionException
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.
- Specified by:
getNextMessage
in class AbstractReceiverResourceWorker
- 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
hasMoreMessages
protected boolean hasMoreMessages(Object message)
- Overrides:
hasMoreMessages
in class AbstractReceiverResourceWorker
handleResults
protected void handleResults(List messages)
throws Exception
- Description copied from class:
AbstractReceiverWorker
- When Mule has finished processing the current messages, there may be zero or more messages to process
by the receiver if request/response messaging is being used. The result(s) should be passed back to the callee.
- Overrides:
handleResults
in class AbstractReceiverWorker
- Parameters:
messages
- a list of messages. This argument will not be null
- Throws:
Exception
preRouteMuleMessage
protected void preRouteMuleMessage(MuleMessage message)
throws Exception
- Description copied from class:
AbstractReceiverWorker
- This callback is called before a message is routed into Mule and can be used by the worker to set connection
specific properties to message before it gets routed
- Overrides:
preRouteMuleMessage
in class AbstractReceiverWorker
- Parameters:
message
- the next message to be processed
- Throws:
Exception
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.