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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
accepted()
void
addInboundRateLimiter(RateLimiter limiter)
void
addOutboundRateLimiter(RateLimiter limiter)
void
close()
void
connect(java.nio.ByteBuffer initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
Connection
getConnection()
GenericMessageEndpoint
getEndpoint()
int
getMaximumMessageSize()
GenericMessageStartpoint
getStartpoint()
int
getTransportType()
java.lang.String
getType()
void
removeInboundRateLimiter(RateLimiter limiter)
void
removeOutboundRateLimiter(RateLimiter limiter)
void
send(PooledByteBuffer message)
void
setOwner(GenericMessageConnectionImpl _owner)
-
-
-
Method Detail
-
setOwner
void setOwner(GenericMessageConnectionImpl _owner)
-
getEndpoint
GenericMessageEndpoint getEndpoint()
-
getStartpoint
GenericMessageStartpoint getStartpoint()
-
getMaximumMessageSize
int getMaximumMessageSize()
-
getType
java.lang.String getType()
-
getTransportType
int getTransportType()
-
connect
void connect(java.nio.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
-
-