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, org.mule.api.lifecycle.Disposable, org.mule.util.monitor.Expirable

Direct Known Subclasses:

ExceptionReturnTcpMessageReceiver.TcpWorker

Enclosing class:

TcpMessageReceiver

protected class TcpMessageReceiver.TcpWorker
extends org.mule.transport.AbstractReceiverResourceWorker
implements org.mule.api.lifecycle.Disposable, org.mule.util.monitor.Expirable

Field Summary

Fields

Modifier and Type	Field and Description
protected TcpInputStream	dataIn
protected boolean	dataInWorkFinished
protected OutputStream	dataOut
protected Object	notify
protected TcpProtocol	protocol
protected Socket	socket
protected InputStream	underlyingIn

Fields inherited from class org.mule.transport.AbstractReceiverResourceWorker

resource

Fields inherited from class org.mule.transport.AbstractReceiverWorker

endpoint, messages, out, receiver

Fields inherited from interface org.mule.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
TcpMessageReceiver.TcpWorker(Socket socket, org.mule.transport.AbstractMessageReceiver receiver)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	bindTransaction(org.mule.api.transaction.Transaction tx)
void	dispose()
void	expired()
protected Object	getNextMessage(Object resource)
protected void	handleResults(List messages)
protected boolean	hasMoreMessages(Object message)
protected void	preRouteMuleMessage(org.mule.api.MuleMessage message)
void	release()
protected void	shutdownSocket()

Methods inherited from class org.mule.transport.AbstractReceiverResourceWorker

doRun

Methods inherited from class org.mule.transport.AbstractReceiverWorker

handleEventResults, postProcessMessage, preProcessMessage, processMessages, run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

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

Constructor Detail

TcpMessageReceiver.TcpWorker

public TcpMessageReceiver.TcpWorker(Socket socket,
                            org.mule.transport.AbstractMessageReceiver receiver)
                             throws IOException

Throws:

IOException

Method Detail

expired

public void expired()

Specified by:

expired in interface org.mule.util.monitor.Expirable

dispose

public void dispose()

Specified by:

dispose in interface org.mule.api.lifecycle.Disposable

release

public void release()

Specified by:

release in interface javax.resource.spi.work.Work

Overrides:

release in class org.mule.transport.AbstractReceiverWorker

shutdownSocket

protected void shutdownSocket()
                       throws IOException

Throws:

IOException

bindTransaction

protected void bindTransaction(org.mule.api.transaction.Transaction tx)
                        throws org.mule.api.transaction.TransactionException

Specified by:

bindTransaction in class org.mule.transport.AbstractReceiverWorker

Throws:

org.mule.api.transaction.TransactionException

getNextMessage

protected Object getNextMessage(Object resource)
                         throws Exception

Specified by:

getNextMessage in class org.mule.transport.AbstractReceiverResourceWorker

Throws:

Exception

hasMoreMessages

protected boolean hasMoreMessages(Object message)

Overrides:

hasMoreMessages in class org.mule.transport.AbstractReceiverResourceWorker

handleResults

protected void handleResults(List messages)
                      throws Exception

Overrides:

handleResults in class org.mule.transport.AbstractReceiverWorker

Throws:

Exception

preRouteMuleMessage

protected void preRouteMuleMessage(org.mule.api.MuleMessage message)
                            throws Exception

Overrides:

preRouteMuleMessage in class org.mule.transport.AbstractReceiverWorker

Throws:

Exception