org.infinispan.client.hotrod.impl.transport

Interface Transport

All Known Implementing Classes:

AbstractTransport, TcpTransport

public interface Transport

Transport abstraction.

Since:

4.1

Author:

Mircea.Markus@jboss.com

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	dumpStream()
void	flush()
SocketAddress	getRemoteSocketAddress() Returns the address of the endpoint this transport is connected to, or null if it is unconnected.
TransportFactory	getTransportFactory()
void	invalidate() Invalidates transport instance.
int	read4ByteInt()
byte[]	readArray() reads an vint which is size; then an array having that size.
short	readByte()
byte[]	readByteArray(int size)
long	readLong()
String	readString()
int	readUnsignedShort()
int	readVInt()
long	readVLong()
void	release()
void	writeArray(byte[] toAppend)
void	writeByte(short toWrite)
void	writeLong(long longValue)
void	writeString(String string)
void	writeVInt(int vint)
void	writeVLong(long l)

Method Detail

getTransportFactory

TransportFactory getTransportFactory()

writeArray

void writeArray(byte[] toAppend)

writeByte

void writeByte(short toWrite)

writeVInt

void writeVInt(int vint)

writeVLong

void writeVLong(long l)

readVLong

long readVLong()

readVInt

int readVInt()

flush

void flush()

readByte

short readByte()

release

void release()

readArray

byte[] readArray()

reads an vint which is size; then an array having that size.

readString

String readString()

readByteArray

byte[] readByteArray(int size)

readLong

long readLong()

writeLong

void writeLong(long longValue)

readUnsignedShort

int readUnsignedShort()

read4ByteInt

int read4ByteInt()

writeString

void writeString(String string)

dumpStream

byte[] dumpStream()

getRemoteSocketAddress

SocketAddress getRemoteSocketAddress()

Returns the address of the endpoint this transport is connected to, or null if it is unconnected.

Returns:

a SocketAddress reprensenting the remote endpoint of this transport, or null if it is not connected yet.

invalidate

void invalidate()

Invalidates transport instance.