Package | Description |
---|---|
org.apache.cassandra.net |
Modifier and Type | Field and Description |
---|---|
static java.util.List<ConnectionType> |
ConnectionType.MESSAGING_TYPES |
Modifier and Type | Method and Description |
---|---|
static ConnectionType |
ConnectionType.fromId(int id) |
ConnectionType |
OutboundConnection.type() |
static ConnectionType |
ConnectionType.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static ConnectionType[] |
ConnectionType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
OutboundSink.accept(Message<?> message,
InetAddressAndPort to,
ConnectionType connectionType) |
void |
OutboundSink.Sink.accept(Message<?> message,
InetAddressAndPort to,
ConnectionType connectionType) |
void |
OutboundConnections.enqueue(Message msg,
ConnectionType type)
Select the appropriate connection for the provided message and use it to send the message.
|
static PingRequest |
PingRequest.get(ConnectionType type) |
void |
MessagingService.send(Message message,
InetAddressAndPort to,
ConnectionType specifyConnection) |
void |
MessagingService.sendWithCallback(Message message,
InetAddressAndPort to,
RequestCallback cb,
ConnectionType specifyConnection) |
Copyright © 2009-2020 The Apache Software Foundation