Package org.apache.cassandra.net
Class OutboundConnections
- java.lang.Object
-
- org.apache.cassandra.net.OutboundConnections
-
public class OutboundConnections extends java.lang.ObjectGroups a set of outbound connections to a given peer, and routes outgoing messages to the appropriate connection (based upon message's type or size). Contains aOutboundConnectionfor each of theConnectionTypetypes.
-
-
Field Summary
Fields Modifier and Type Field Description OutboundConnectionlargestatic intLARGE_MESSAGE_THRESHOLDOutboundConnectionsmallOutboundConnectionurgent
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidenqueue(Message msg, ConnectionType type)Select the appropriate connection for the provided message and use it to send the message.longusingReserveBytes()
-
-
-
Field Detail
-
LARGE_MESSAGE_THRESHOLD
public static final int LARGE_MESSAGE_THRESHOLD
-
small
public final OutboundConnection small
-
large
public final OutboundConnection large
-
urgent
public final OutboundConnection urgent
-
-
Method Detail
-
enqueue
public void enqueue(Message msg, ConnectionType type) throws java.nio.channels.ClosedChannelException
Select the appropriate connection for the provided message and use it to send the message.- Throws:
java.nio.channels.ClosedChannelException
-
usingReserveBytes
public long usingReserveBytes()
-
-