A B C D E F G H I K L M N O P R S T U V W X

A

AbstractByteProtocol - Class in org.mule.transport.tcp.protocols

This Abstract class has been introduced so as to have the byte protocols (i.e.

AbstractByteProtocol(boolean) - Constructor for class org.mule.transport.tcp.protocols.AbstractByteProtocol

AbstractTcpSocketFactory - Class in org.mule.transport.tcp

Creates a client socket using the socket address extracted from the endpoint.

AbstractTcpSocketFactory() - Constructor for class org.mule.transport.tcp.AbstractTcpSocketFactory

activateObject(Object, Object) - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

B

bindTransaction(Transaction) - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

bufferSize - Variable in class org.mule.transport.tcp.protocols.DirectProtocol

ByteOrMessageProtocolDefinitionParser - Class in org.mule.transport.tcp.config

ByteOrMessageProtocolDefinitionParser(Class, Class) - Constructor for class org.mule.transport.tcp.config.ByteOrMessageProtocolDefinitionParser

C

CLIENT - Static variable in class org.mule.transport.tcp.TcpConnector

close() - Method in class org.mule.transport.tcp.protocols.ProtocolStream

configure(ServerSocket, Boolean, InetSocketAddress, int) - Method in class org.mule.transport.tcp.TcpServerSocketFactory

configureSocket(boolean, Socket) - Method in class org.mule.transport.tcp.TcpConnector

COOKIE - Static variable in class org.mule.transport.tcp.protocols.SafeProtocol

copy(InputStream, byte[], OutputStream) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

Make a single transfer from source to dest via a byte array buffer

copy(InputStream, byte[], OutputStream, int) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

Make a single transfer from source to dest via a byte array buffer

copyStream(InputStream, OutputStream) - Method in class org.mule.transport.tcp.protocols.StreamingProtocol

create(OutboundEndpoint) - Method in class org.mule.transport.tcp.LocalSocketTcpMessageDispatcherFactory

create(OutboundEndpoint) - Method in class org.mule.transport.tcp.TcpMessageDispatcherFactory

create(InboundEndpoint) - Method in class org.mule.transport.tcp.TcpMessageRequesterFactory

createResponse(Socket) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

createResponse(Socket) - Method in class org.mule.transport.tcp.protocols.SafeProtocol

createResponse(Socket) - Method in interface org.mule.transport.tcp.TcpProtocol

This lets protocols encode a response stream.

createServerSocket(URI, int, Boolean) - Method in interface org.mule.transport.tcp.SimpleServerSocketFactory

createServerSocket(InetAddress, int, int, Boolean) - Method in interface org.mule.transport.tcp.SimpleServerSocketFactory

createServerSocket(int, int, Boolean) - Method in interface org.mule.transport.tcp.SimpleServerSocketFactory

createServerSocket(URI, int, Boolean) - Method in class org.mule.transport.tcp.TcpServerSocketFactory

createServerSocket(InetAddress, int, int, Boolean) - Method in class org.mule.transport.tcp.TcpServerSocketFactory

createServerSocket(int, int, Boolean) - Method in class org.mule.transport.tcp.TcpServerSocketFactory

createSocket(TcpSocketKey) - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

createSocket(TcpSocketKey) - Method in class org.mule.transport.tcp.TcpSocketFactory

createWork(Socket) - Method in class org.mule.transport.tcp.ExceptionReturnTcpMessageReceiver

createWork(Socket) - Method in class org.mule.transport.tcp.TcpMessageReceiver

CustomClassLoadingLengthProtocol - Class in org.mule.transport.tcp.protocols

A length protocol that uses a specific class loader to load objects from streams

CustomClassLoadingLengthProtocol() - Constructor for class org.mule.transport.tcp.protocols.CustomClassLoadingLengthProtocol

D

dataIn - Variable in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

dataInWorkFinished - Variable in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

dataOut - Variable in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

DEFAULT_BACKLOG - Static variable in class org.mule.transport.tcp.TcpConnector

DEFAULT_BUFFER_SIZE - Static variable in class org.mule.transport.tcp.TcpConnector

DEFAULT_SO_LINGER - Static variable in class org.mule.transport.tcp.TcpConnector

DEFAULT_SOCKET_TIMEOUT - Static variable in class org.mule.transport.tcp.TcpConnector

DEFAULT_WAIT_TIMEOUT - Static variable in class org.mule.transport.tcp.TcpConnector

DefaultTcpClientSocketProperties - Class in org.mule.transport.tcp

Default mutable implementation of the TcpClientSocketProperties interface.

DefaultTcpClientSocketProperties() - Constructor for class org.mule.transport.tcp.DefaultTcpClientSocketProperties

DefaultTcpServerSocketProperties - Class in org.mule.transport.tcp

Default mutable implementation of the TcpServerSocketProperties interface.

DefaultTcpServerSocketProperties() - Constructor for class org.mule.transport.tcp.DefaultTcpServerSocketProperties

destroyObject(Object, Object) - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

DirectProtocol - Class in org.mule.transport.tcp.protocols

The DirectProtocol class is an application level tcp protocol that does nothing.

DirectProtocol() - Constructor for class org.mule.transport.tcp.protocols.DirectProtocol

DirectProtocol(boolean, int) - Constructor for class org.mule.transport.tcp.protocols.DirectProtocol

dispatchToSocket(MuleEvent) - Method in class org.mule.transport.tcp.LocalSocketTcpMessageDispatcher

dispose() - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

disposing - Variable in class org.mule.transport.tcp.TcpMessageReceiver

doConnect() - Method in class org.mule.transport.tcp.TcpConnector

doConnect() - Method in class org.mule.transport.tcp.TcpMessageDispatcher

doConnect() - Method in class org.mule.transport.tcp.TcpMessageReceiver

doConnect() - Method in class org.mule.transport.tcp.TcpMessageRequester

doDisconnect() - Method in class org.mule.transport.tcp.TcpConnector

doDisconnect() - Method in class org.mule.transport.tcp.TcpMessageDispatcher

doDisconnect() - Method in class org.mule.transport.tcp.TcpMessageReceiver

doDisconnect() - Method in class org.mule.transport.tcp.TcpMessageRequester

doDispatch(MuleEvent) - Method in class org.mule.transport.tcp.LocalSocketTcpMessageDispatcher

doDispatch(MuleEvent) - Method in class org.mule.transport.tcp.TcpMessageDispatcher

doDispose() - Method in class org.mule.transport.tcp.TcpConnector

doDispose() - Method in class org.mule.transport.tcp.TcpMessageDispatcher

doDispose() - Method in class org.mule.transport.tcp.TcpMessageReceiver

doDispose() - Method in class org.mule.transport.tcp.TcpMessageRequester

doInitialise() - Method in class org.mule.transport.tcp.TcpConnector

doRequest(long) - Method in class org.mule.transport.tcp.TcpMessageRequester

Make a specific request to the underlying transport

doSend(MuleEvent) - Method in class org.mule.transport.tcp.LocalSocketTcpMessageDispatcher

doSend(MuleEvent) - Method in class org.mule.transport.tcp.TcpMessageDispatcher

doStart() - Method in class org.mule.transport.tcp.TcpConnector

doStart() - Method in class org.mule.transport.tcp.TcpMessageReceiver

doStop() - Method in class org.mule.transport.tcp.TcpConnector

doStop() - Method in class org.mule.transport.tcp.TcpMessageReceiver

E

EOF - Static variable in class org.mule.transport.tcp.protocols.AbstractByteProtocol

EOFProtocol - Class in org.mule.transport.tcp.protocols

The EOFProtocol class is an application level tcp protocol that does nothing.

EOFProtocol() - Constructor for class org.mule.transport.tcp.protocols.EOFProtocol

equals(Object) - Method in class org.mule.transport.tcp.TcpSocketKey

ExceptionReturnTcpMessageReceiver - Class in org.mule.transport.tcp

Extends TcpMessageReceiver providing managing of protocol error conditions.

ExceptionReturnTcpMessageReceiver(Connector, FlowConstruct, InboundEndpoint) - Constructor for class org.mule.transport.tcp.ExceptionReturnTcpMessageReceiver

ExceptionReturnTcpMessageReceiver.TcpWorker - Class in org.mule.transport.tcp

ExceptionReturnTcpMessageReceiver.TcpWorker(Socket, AbstractMessageReceiver) - Constructor for class org.mule.transport.tcp.ExceptionReturnTcpMessageReceiver.TcpWorker

expired() - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

F

failedToBindToUri(URI) - Static method in class org.mule.transport.tcp.i18n.TcpMessages

failedToCloseSocket() - Static method in class org.mule.transport.tcp.i18n.TcpMessages

failedToInitMessageReader() - Static method in class org.mule.transport.tcp.i18n.TcpMessages

flush() - Method in class org.mule.transport.tcp.protocols.ProtocolStream

G

getBacklog() - Method in class org.mule.transport.tcp.TcpConnector

Deprecated.

should use TcpConnector.getReceiveBacklog()

getBufferSize() - Method in class org.mule.transport.tcp.TcpConnector

Deprecated.

Should use TcpConnector.getSendBufferSize() or TcpConnector.getReceiveBufferSize()

getClassLoader() - Method in class org.mule.transport.tcp.protocols.CustomClassLoadingLengthProtocol

getClientSoTimeout() - Method in class org.mule.transport.tcp.TcpConnector

getConnectionTimeout() - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

getConnectionTimeout() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getConnectionTimeout() - Method in interface org.mule.transport.tcp.TcpClientSocketProperties

getConnectionTimeout() - Method in class org.mule.transport.tcp.TcpConnector

getConnector() - Method in class org.mule.transport.tcp.LocalSocketTcpMessageDispatcher

getConnector() - Method in class org.mule.transport.tcp.TcpSocketKey

getDispatchers() - Method in class org.mule.transport.tcp.TcpConnector

getEndpoint() - Method in class org.mule.transport.tcp.TcpSocketKey

getInetAddress() - Method in class org.mule.transport.tcp.TcpSocketKey

getKeepAlive() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getKeepAlive() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getKeepAlive() - Method in interface org.mule.transport.tcp.TcpClientSocketProperties

getKeepAlive() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getKeepAliveMonitor() - Method in class org.mule.transport.tcp.TcpConnector

getKeepAliveTimeout() - Method in class org.mule.transport.tcp.TcpConnector

getLimit() - Method in class org.mule.transport.tcp.protocols.StreamingProtocol

getLinger() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getLinger() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getLinger() - Method in interface org.mule.transport.tcp.TcpClientSocketProperties

getLinger() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getMaxMessageLength() - Method in class org.mule.transport.tcp.protocols.LengthProtocol

getName() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getName() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getNextMessage(Object) - Method in class org.mule.transport.tcp.ExceptionReturnTcpMessageReceiver.TcpWorker

getNextMessage(Object) - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

getOutputStream(ImmutableEndpoint, MuleMessage) - Method in class org.mule.transport.tcp.TcpConnector

getPollingFrequency() - Method in class org.mule.transport.tcp.PollingTcpConnector

getPort() - Method in class org.mule.transport.tcp.TcpSocketKey

getProtocol() - Method in class org.mule.transport.tcp.TcpConnector

getReceiveBacklog() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getReceiveBacklog() - Method in class org.mule.transport.tcp.TcpConnector

getReceiveBacklog() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getReceiveBufferSize() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getReceiveBufferSize() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getReceiveBufferSize() - Method in interface org.mule.transport.tcp.TcpClientSocketProperties

getReceiveBufferSize() - Method in class org.mule.transport.tcp.TcpConnector

getReceiveBufferSize() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getReuseAddress() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getReuseAddress() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getSendBufferSize() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getSendBufferSize() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getSendBufferSize() - Method in interface org.mule.transport.tcp.TcpClientSocketProperties

getSendBufferSize() - Method in class org.mule.transport.tcp.TcpConnector

getSendBufferSize() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getSendTcpNoDelay() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getSendTcpNoDelay() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getSendTcpNoDelay() - Method in interface org.mule.transport.tcp.TcpClientSocketProperties

getSendTcpNoDelay() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getServerSocket(URI) - Method in class org.mule.transport.tcp.TcpConnector

getServerSocket() - Method in class org.mule.transport.tcp.TcpMessageReceiver

Obtain the serverSocket

getServerSocketFactory() - Method in class org.mule.transport.tcp.TcpConnector

getServerSoTimeout() - Method in class org.mule.transport.tcp.TcpConnector

getServerTimeout() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getServerTimeout() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

getSocket(ImmutableEndpoint) - Method in class org.mule.transport.tcp.TcpConnector

Lookup a socket in the list of dispatcher sockets but don't create a new socket

getSocketFactory() - Method in class org.mule.transport.tcp.TcpConnector

getSocketMaxWait() - Method in class org.mule.transport.tcp.TcpConnector

getSocketSoLinger() - Method in class org.mule.transport.tcp.TcpConnector

getSocketsPoolMaxActive() - Method in class org.mule.transport.tcp.TcpConnector

getSocketsPoolMaxIdle() - Method in class org.mule.transport.tcp.TcpConnector

getSocketsPoolMaxWait() - Method in class org.mule.transport.tcp.TcpConnector

getSocketsPoolNumActive() - Method in class org.mule.transport.tcp.TcpConnector

getTcpProtocol() - Method in class org.mule.transport.tcp.TcpConnector

getTimeout() - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

getTimeout() - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

getTimeout() - Method in interface org.mule.transport.tcp.TcpClientSocketProperties

getTimeout() - Method in interface org.mule.transport.tcp.TcpServerSocketProperties

H

handleResults(List) - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

hashCode() - Method in class org.mule.transport.tcp.TcpSocketKey

hasMoreMessages(Object) - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

I

init() - Method in class org.mule.transport.tcp.config.TcpNamespaceHandler

invalidStreamingOutputType(Class) - Static method in class org.mule.transport.tcp.i18n.TcpMessages

isBindingLocalhostToAllLocalInterfaces() - Static method in class org.mule.transport.tcp.TcpPropertyHelper

Returns whether localhost should be bound to all local interfaces or not.

isFailOnUnresolvedHost() - Method in class org.mule.transport.tcp.TcpConnector

isKeepAlive() - Method in class org.mule.transport.tcp.TcpConnector

isKeepSendSocketOpen() - Method in class org.mule.transport.tcp.TcpConnector

isRepeat(int, int) - Method in class org.mule.transport.tcp.protocols.DirectProtocol

Decide whether to repeat transfer.

isRepeat(int, int) - Method in class org.mule.transport.tcp.protocols.EOFProtocol

Repeat until end of file

isRepeat(int, int) - Method in class org.mule.transport.tcp.protocols.LengthProtocol

Read all four bytes for initial integer (limit is set in read)

isRepeat(int, int, int) - Method in class org.mule.transport.tcp.protocols.XmlMessageEOFProtocol

Continue reading til EOF or new document found

isRepeat(int, int, int) - Method in class org.mule.transport.tcp.protocols.XmlMessageProtocol

Show we continue reading? This class, following previous implementations, only reads while input is saturated.

isResponseEnabled() - Method in class org.mule.transport.tcp.TcpConnector

isRethrowExceptionOnRead() - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

isReuseAddress() - Method in class org.mule.transport.tcp.TcpConnector

isSendTcpNoDelay() - Method in class org.mule.transport.tcp.TcpConnector

isStreaming() - Method in class org.mule.transport.tcp.TcpInputStream

K

KEEP_SEND_SOCKET_OPEN_PROPERTY - Static variable in class org.mule.transport.tcp.TcpConnector

Property can be set on the endpoint to configure how the socket is managed

L

LengthProtocol - Class in org.mule.transport.tcp.protocols

The LengthProtocol is an application level tcp protocol that can be used to transfer large amounts of data without risking some data to be loss.

LengthProtocol() - Constructor for class org.mule.transport.tcp.protocols.LengthProtocol

LengthProtocol(int) - Constructor for class org.mule.transport.tcp.protocols.LengthProtocol

localhostBoundToAllLocalInterfaces() - Static method in class org.mule.transport.tcp.i18n.TcpMessages

LocalSocketTcpMessageDispatcher - Class in org.mule.transport.tcp

LocalSocketTcpMessageDispatcher will send transformed Mule events over TCP.

LocalSocketTcpMessageDispatcher(OutboundEndpoint) - Constructor for class org.mule.transport.tcp.LocalSocketTcpMessageDispatcher

LocalSocketTcpMessageDispatcherFactory - Class in org.mule.transport.tcp

A factory for LocalSocketTcpMessageDispatcher

LocalSocketTcpMessageDispatcherFactory() - Constructor for class org.mule.transport.tcp.LocalSocketTcpMessageDispatcherFactory

logger - Variable in class org.mule.transport.tcp.TcpServerSocketFactory

M

makeObject(Object) - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

MULE_TCP_BIND_LOCALHOST_TO_ALL_LOCAL_INTERFACES_PROPERTY - Static variable in class org.mule.transport.tcp.TcpPropertyHelper

MuleMessageDirectProtocol - Class in org.mule.transport.tcp.protocols

This Protocol will send the actual Mule Message over the TCP channel, and in this way we are preserving any headers which might be needed, for example Correlation IDs in order to be able to aggregate messages after chunking.

MuleMessageDirectProtocol() - Constructor for class org.mule.transport.tcp.protocols.MuleMessageDirectProtocol

MuleMessageEOFProtocol - Class in org.mule.transport.tcp.protocols

This Protocol will send the actual Mule Message over the TCP channel, and in this way we are preserving any headers which might be needed, for example Correlation IDs in order to be able to aggregate messages after chunking.

MuleMessageEOFProtocol() - Constructor for class org.mule.transport.tcp.protocols.MuleMessageEOFProtocol

MuleMessageLengthProtocol - Class in org.mule.transport.tcp.protocols

This Protocol will send the actual Mule Message over the TCP channel, and in this way we are preserving any headers which might be needed, for example Correlation IDs in order to be able to aggregate messages after chunking.

MuleMessageLengthProtocol() - Constructor for class org.mule.transport.tcp.protocols.MuleMessageLengthProtocol

MuleMessageSafeProtocol - Class in org.mule.transport.tcp.protocols

This Protocol will send the actual Mule Message over the TCP channel, and in this way we are preserving any headers which might be needed, for example Correlation IDs in order to be able to aggregate messages after chunking.

MuleMessageSafeProtocol() - Constructor for class org.mule.transport.tcp.protocols.MuleMessageSafeProtocol

N

NO_MAX_LENGTH - Static variable in class org.mule.transport.tcp.protocols.LengthProtocol

NO_STREAM - Static variable in class org.mule.transport.tcp.protocols.AbstractByteProtocol

notify - Variable in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

nullEmptyArray(byte[]) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

O

org.mule.transport.tcp - package org.mule.transport.tcp

Provides tcp connectivity for Mule.

org.mule.transport.tcp.config - package org.mule.transport.tcp.config

Configuration classes for processing Xml config elements within the TCP namespace.

org.mule.transport.tcp.i18n - package org.mule.transport.tcp.i18n

org.mule.transport.tcp.protocols - package org.mule.transport.tcp.protocols

P

passivateObject(Object, Object) - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

poll() - Method in class org.mule.transport.tcp.PollingTcpMessageReceiver

pollingReceiverCannotbeUsed() - Static method in class org.mule.transport.tcp.i18n.TcpMessages

PollingTcpConnector - Class in org.mule.transport.tcp

PollingTcpMessageReceiver acts as a polling TCP connector.

PollingTcpConnector(MuleContext) - Constructor for class org.mule.transport.tcp.PollingTcpConnector

PollingTcpMessageReceiver - Class in org.mule.transport.tcp

PollingTcpMessageReceiver acts like a TCP client polling for new messages.

PollingTcpMessageReceiver(Connector, FlowConstruct, InboundEndpoint) - Constructor for class org.mule.transport.tcp.PollingTcpMessageReceiver

preRouteMuleMessage(MuleMessage) - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

PROTOCOL - Static variable in class org.mule.transport.tcp.config.ByteOrMessageProtocolDefinitionParser

protocol - Variable in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

ProtocolStream - Class in org.mule.transport.tcp.protocols

ProtocolStream(TcpProtocol, boolean, OutputStream) - Constructor for class org.mule.transport.tcp.protocols.ProtocolStream

R

read(InputStream) - Method in class org.mule.transport.tcp.protocols.CustomClassLoadingLengthProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.DirectProtocol

read(InputStream, int) - Method in class org.mule.transport.tcp.protocols.DirectProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.LengthProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.MuleMessageDirectProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.MuleMessageEOFProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.MuleMessageLengthProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.MuleMessageSafeProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.SafeProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.StreamingProtocol

read(InputStream) - Method in class org.mule.transport.tcp.protocols.XmlMessageProtocol

read(InputStream) - Method in interface org.mule.transport.tcp.TcpProtocol

Reads the input stream and returns a whole message.

receiveFromSocket(Socket, int, ImmutableEndpoint) - Static method in class org.mule.transport.tcp.TcpMessageDispatcher

release() - Method in class org.mule.transport.tcp.TcpMessageReceiver

release() - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

remaining(int, int, int) - Method in class org.mule.transport.tcp.protocols.DirectProtocol

run() - Method in class org.mule.transport.tcp.TcpMessageReceiver

S

SafeProtocol - Class in org.mule.transport.tcp.protocols

This precedes every message with a cookie.

SafeProtocol() - Constructor for class org.mule.transport.tcp.protocols.SafeProtocol

safeRead(InputStream, byte[]) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

Manage non-blocking reads and handle errors

safeRead(InputStream, byte[], int) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

Manage non-blocking reads and handle errors

SEND_TCP_NO_DELAY_SYSTEM_PROPERTY - Static variable in class org.mule.transport.tcp.TcpConnector

SERVER - Static variable in class org.mule.transport.tcp.TcpConnector

setBacklog(int) - Method in class org.mule.transport.tcp.TcpConnector

Deprecated.

should use TcpConnector.setReceiveBacklog(int)

setBufferSize(int) - Method in class org.mule.transport.tcp.TcpConnector

Deprecated.

Should use TcpConnector.setSendBufferSize(int) or TcpConnector.setReceiveBufferSize(int)

setClassLoader(ClassLoader) - Method in class org.mule.transport.tcp.protocols.CustomClassLoadingLengthProtocol

setClientSoTimeout(int) - Method in class org.mule.transport.tcp.TcpConnector

setConnectionTimeout(int) - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

setConnectionTimeout(Integer) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setConnectionTimeout(int) - Method in class org.mule.transport.tcp.TcpConnector

setDispatcherFactory(MessageDispatcherFactory) - Method in class org.mule.transport.tcp.TcpConnector

setFailOnUnresolvedHost(Boolean) - Method in class org.mule.transport.tcp.TcpConnector

setKeepAlive(Boolean) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setKeepAlive(Boolean) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setKeepAlive(boolean) - Method in class org.mule.transport.tcp.TcpConnector

setKeepAliveTimeout(int) - Method in class org.mule.transport.tcp.TcpConnector

Sets the keep alive timeout (in Milliseconds)

setKeepSendSocketOpen(boolean) - Method in class org.mule.transport.tcp.TcpConnector

setLinger(Integer) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setLinger(Integer) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setMaxMessageLength(int) - Method in class org.mule.transport.tcp.protocols.LengthProtocol

setMaxMessageLength(int) - Method in class org.mule.transport.tcp.protocols.SafeProtocol

setMuleContext(MuleContext) - Method in class org.mule.transport.tcp.protocols.MuleMessageDirectProtocol

setMuleContext(MuleContext) - Method in class org.mule.transport.tcp.protocols.MuleMessageEOFProtocol

setMuleContext(MuleContext) - Method in class org.mule.transport.tcp.protocols.MuleMessageLengthProtocol

setMuleContext(MuleContext) - Method in class org.mule.transport.tcp.protocols.MuleMessageSafeProtocol

setName(String) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setName(String) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setObjectSerializer(ObjectSerializer) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

setObjectSerializer(ObjectSerializer) - Method in class org.mule.transport.tcp.protocols.SafeProtocol

setPollingFrequency(long) - Method in class org.mule.transport.tcp.PollingTcpConnector

setReceiveBacklog(Integer) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setReceiveBacklog(int) - Method in class org.mule.transport.tcp.TcpConnector

setReceiveBufferSize(Integer) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setReceiveBufferSize(Integer) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setReceiveBufferSize(int) - Method in class org.mule.transport.tcp.TcpConnector

setRethrowExceptionOnRead(boolean) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

setReuseAddress(Boolean) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setReuseAddress(Boolean) - Method in class org.mule.transport.tcp.TcpConnector

This allows closed sockets to be reused while they are still in TIME_WAIT state

setSendBufferSize(Integer) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setSendBufferSize(Integer) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setSendBufferSize(int) - Method in class org.mule.transport.tcp.TcpConnector

setSendTcpNoDelay(Boolean) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setSendTcpNoDelay(Boolean) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setSendTcpNoDelay(boolean) - Method in class org.mule.transport.tcp.TcpConnector

setServerSocketFactory(SimpleServerSocketFactory) - Method in class org.mule.transport.tcp.TcpConnector

setServerSoTimeout(int) - Method in class org.mule.transport.tcp.TcpConnector

setServerTimeout(Integer) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setSocketFactory(AbstractTcpSocketFactory) - Method in class org.mule.transport.tcp.TcpConnector

setSocketMaxWait(int) - Method in class org.mule.transport.tcp.TcpConnector

setSocketSoLinger(int) - Method in class org.mule.transport.tcp.TcpConnector

setStreaming(boolean) - Method in class org.mule.transport.tcp.TcpInputStream

setTcpProtocol(TcpProtocol) - Method in class org.mule.transport.tcp.TcpConnector

setTimeout(Integer) - Method in class org.mule.transport.tcp.DefaultTcpClientSocketProperties

setTimeout(Integer) - Method in class org.mule.transport.tcp.DefaultTcpServerSocketProperties

setTimeout(int) - Method in class org.mule.transport.tcp.TcpConnector

Deprecated.

The time out should be set explicitly for each

shutdownSocket() - Method in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

SimpleServerSocketFactory - Interface in org.mule.transport.tcp

socket - Variable in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

STREAM_OK - Static variable in class org.mule.transport.tcp.protocols.AbstractByteProtocol

StreamingProtocol - Class in org.mule.transport.tcp.protocols

StreamingProtocol() - Constructor for class org.mule.transport.tcp.protocols.StreamingProtocol

T

TCP - Static variable in class org.mule.transport.tcp.TcpConnector

TcpClientSocketProperties - Interface in org.mule.transport.tcp

Interface for objects that provide TCP configuration for client sockets.

TcpConnector - Class in org.mule.transport.tcp

TcpConnector can bind or sent to a given TCP port on a given host.

TcpConnector(MuleContext) - Constructor for class org.mule.transport.tcp.TcpConnector

TcpInputStream - Class in org.mule.transport.tcp

The TcpMessageDispatcher and the TcpMessageReceiver use this class as the input parameter to the read() method on the TcpProtocol interface.

TcpInputStream(InputStream) - Constructor for class org.mule.transport.tcp.TcpInputStream

TcpMessageDispatcher - Class in org.mule.transport.tcp

Send transformed Mule events over TCP.

TcpMessageDispatcher(OutboundEndpoint) - Constructor for class org.mule.transport.tcp.TcpMessageDispatcher

TcpMessageDispatcherFactory - Class in org.mule.transport.tcp

TcpMessageDispatcherFactory() - Constructor for class org.mule.transport.tcp.TcpMessageDispatcherFactory

TcpMessageReceiver - Class in org.mule.transport.tcp

TcpMessageReceiver acts like a TCP server to receive socket requests.

TcpMessageReceiver(Connector, FlowConstruct, InboundEndpoint) - Constructor for class org.mule.transport.tcp.TcpMessageReceiver

TcpMessageReceiver.TcpWorker - Class in org.mule.transport.tcp

TcpMessageReceiver.TcpWorker(Socket, AbstractMessageReceiver) - Constructor for class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

TcpMessageRequester - Class in org.mule.transport.tcp

Request transformed Mule events from TCP.

TcpMessageRequester(InboundEndpoint) - Constructor for class org.mule.transport.tcp.TcpMessageRequester

TcpMessageRequesterFactory - Class in org.mule.transport.tcp

TcpMessageRequesterFactory() - Constructor for class org.mule.transport.tcp.TcpMessageRequesterFactory

TcpMessages - Class in org.mule.transport.tcp.i18n

TcpMessages() - Constructor for class org.mule.transport.tcp.i18n.TcpMessages

TcpNamespaceHandler - Class in org.mule.transport.tcp.config

Registers a Bean Definition Parser for handling elements.

TcpNamespaceHandler() - Constructor for class org.mule.transport.tcp.config.TcpNamespaceHandler

TcpPropertyHelper - Class in org.mule.transport.tcp

Helper class to read properties for the TCP transport.

TcpPropertyHelper() - Constructor for class org.mule.transport.tcp.TcpPropertyHelper

TcpProtocol - Interface in org.mule.transport.tcp

The TcpProtocol interface enables to plug different application level protocols on a TcpConnector.

TcpServerSocketFactory - Class in org.mule.transport.tcp

TcpServerSocketFactory() - Constructor for class org.mule.transport.tcp.TcpServerSocketFactory

TcpServerSocketProperties - Interface in org.mule.transport.tcp

Interface for objects that provide TCP configuration for server sockets.

TcpSocketFactory - Class in org.mule.transport.tcp

TcpSocketFactory() - Constructor for class org.mule.transport.tcp.TcpSocketFactory

TcpSocketKey - Class in org.mule.transport.tcp

This is used to adapt an endpoint so that it can be used as a key for sockets.

TcpSocketKey(ImmutableEndpoint) - Constructor for class org.mule.transport.tcp.TcpSocketKey

toString() - Method in class org.mule.transport.tcp.TcpSocketKey

U

underlyingIn - Variable in class org.mule.transport.tcp.TcpMessageReceiver.TcpWorker

UNLIMITED - Static variable in class org.mule.transport.tcp.protocols.DirectProtocol

V

validateConnection(RetryContext) - Method in class org.mule.transport.tcp.LocalSocketTcpMessageDispatcher

validateConnection(RetryContext) - Method in class org.mule.transport.tcp.TcpMessageDispatcher

validateConnection(RetryContext) - Method in class org.mule.transport.tcp.TcpMessageRequester

validateObject(Object, Object) - Method in class org.mule.transport.tcp.AbstractTcpSocketFactory

W

write(OutputStream, Object) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

write(OutputStream, Object) - Method in class org.mule.transport.tcp.protocols.MuleMessageDirectProtocol

write(OutputStream, Object) - Method in class org.mule.transport.tcp.protocols.MuleMessageEOFProtocol

write(OutputStream, Object) - Method in class org.mule.transport.tcp.protocols.MuleMessageLengthProtocol

write(OutputStream, Object) - Method in class org.mule.transport.tcp.protocols.MuleMessageSafeProtocol

write(byte[]) - Method in class org.mule.transport.tcp.protocols.ProtocolStream

write(byte[], int, int) - Method in class org.mule.transport.tcp.protocols.ProtocolStream

write(int) - Method in class org.mule.transport.tcp.protocols.ProtocolStream

write(OutputStream, Object) - Method in class org.mule.transport.tcp.protocols.SafeProtocol

write(OutputStream, Object) - Method in interface org.mule.transport.tcp.TcpProtocol

Write the specified message to the output stream.

writeByteArray(OutputStream, byte[]) - Method in class org.mule.transport.tcp.protocols.AbstractByteProtocol

writeByteArray(OutputStream, byte[]) - Method in class org.mule.transport.tcp.protocols.LengthProtocol

X

XmlMessageEOFProtocol - Class in org.mule.transport.tcp.protocols

Extend XmlMessageProtocol to continue reading until either a new message or EOF is found.

XmlMessageEOFProtocol() - Constructor for class org.mule.transport.tcp.protocols.XmlMessageEOFProtocol

XmlMessageProtocol - Class in org.mule.transport.tcp.protocols

The XmlMessageProtocol is an application level tcp protocol that can be used to read streaming xml documents.

XmlMessageProtocol() - Constructor for class org.mule.transport.tcp.protocols.XmlMessageProtocol

A B C D E F G H I K L M N O P R S T U V W X