Package org.apache.cassandra.net

Class OutboundConnections

java.lang.Object

org.apache.cassandra.net.OutboundConnections

public class OutboundConnections
extends Object

Groups 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 a OutboundConnection for each of the ConnectionType types.

Field Summary

Fields

Modifier and Type	Field	Description
final OutboundConnection	large
static final int	LARGE_MESSAGE_THRESHOLD
final OutboundConnection	small
final OutboundConnection	urgent

Method Summary

Modifier and Type	Method	Description
void	enqueue(Message msg, ConnectionType type)	Select the appropriate connection for the provided message and use it to send the message.
long	usingReserveBytes()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

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 Details

enqueue

public void enqueue(Message msg,
 ConnectionType type)
             throws ClosedChannelException

Select the appropriate connection for the provided message and use it to send the message.

Throws:

ClosedChannelException

usingReserveBytes

public long usingReserveBytes()