Interface GenericMessageConnectionAdapter

All Known Implementing Classes:

GenericMessageConnectionDirect, GenericMessageConnectionIndirect

public interface GenericMessageConnectionAdapter

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	GenericMessageConnectionAdapter.ConnectionListener

Method Summary

Modifier and Type	Method	Description
void	accepted()
void	addInboundRateLimiter(RateLimiter limiter)
void	addOutboundRateLimiter(RateLimiter limiter)
void	close()
void	connect(ByteBuffer initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
Connection	getConnection()
GenericMessageEndpoint	getEndpoint()
int	getMaximumMessageSize()
GenericMessageStartpoint	getStartpoint()
int	getTransportType()
String	getType()
void	removeInboundRateLimiter(RateLimiter limiter)
void	removeOutboundRateLimiter(RateLimiter limiter)
void	send(PooledByteBuffer message)
void	setOwner(GenericMessageConnectionImpl _owner)

Method Details

setOwner

void setOwner(GenericMessageConnectionImpl _owner)

getEndpoint

GenericMessageEndpoint getEndpoint()

getStartpoint

GenericMessageStartpoint getStartpoint()

getMaximumMessageSize

int getMaximumMessageSize()

getType

String getType()

getTransportType

int getTransportType()

connect

void connect(ByteBuffer initial_data,
 GenericMessageConnectionAdapter.ConnectionListener listener)

accepted

void accepted()

getConnection

Connection getConnection()

send

void send(PooledByteBuffer message)
   throws MessageException

Throws:

MessageException

addInboundRateLimiter

void addInboundRateLimiter(RateLimiter limiter)

removeInboundRateLimiter

void removeInboundRateLimiter(RateLimiter limiter)

addOutboundRateLimiter

void addOutboundRateLimiter(RateLimiter limiter)

removeOutboundRateLimiter

void removeOutboundRateLimiter(RateLimiter limiter)

close

void close()
    throws MessageException

Throws:

MessageException