Package org.apache.cassandra.transport
package org.apache.cassandra.transport
-
ClassDescriptionCBCodec<T>ByteBuf utility methods.CQLMessageHandler<M extends Message>Implementation of
AbstractMessageHandlerfor processing CQL messages which comprise aMessagewrapped in anEnvelope.Added to the Netty pipeline whenever a new Channel is initialized.A message from the CQL binary protocol.Message.Codec<M extends Message>Takes care of intializing a Netty Channel and Pipeline for client protocol connections.Pre-V5 exception handler which closes the connection if anProtocolExceptionis thrownWraps anDispatcherso that it can be used as an channel inbound handler in pre-V5 pipelines.Simple adaptor to allowMessage.Decoder.decodeMessage(Channel, Envelope)to be used as a handler in pre-V5 pipelinesSimple adaptor to plug CQL message encoding into pre-V5 pipelinesExceptions thrown when a client didn't respect the protocol.The native (CQL binary) protocol version.This class tracks the last 100 connections per protocol versionNative Queue Backpressure mechanism.Exceptions thrown when a client didn't respect the protocol.