Package org.apache.cassandra.transport

Class Message

java.lang.Object

org.apache.cassandra.transport.Message

Direct Known Subclasses:

Message.Request, Message.Response

public abstract class Message
extends Object

A message from the CQL binary protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Message.Codec<M extends Message>
static enum	Message.Direction
static class	Message.Request
static class	Message.Response
static enum	Message.Type

Field Summary

Fields

Modifier and Type	Field	Description
protected Connection	connection
protected ProtocolVersion	forcedProtocolVersion
protected static final org.slf4j.Logger	logger
final Message.Type	type

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Message(Message.Type type)

Method Summary

Modifier and Type	Method	Description
void	attach(Connection connection)
Connection	connection()
Envelope	encode(ProtocolVersion version)
Map<String,ByteBuffer>	getCustomPayload()
Envelope	getSource()
int	getStreamId()
void	setCustomPayload(Map<String,ByteBuffer> customPayload)
void	setSource(Envelope source)
Message	setStreamId(int streamId)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

type

public final Message.Type type

connection

protected Connection connection

forcedProtocolVersion

protected ProtocolVersion forcedProtocolVersion

Constructor Details

Message

protected Message(Message.Type type)

Method Details

attach

public void attach(Connection connection)

connection

public Connection connection()

setStreamId

public Message setStreamId(int streamId)

getStreamId

public int getStreamId()

setSource

public void setSource(Envelope source)

getSource

public Envelope getSource()

getCustomPayload

public Map<String,ByteBuffer> getCustomPayload()

setCustomPayload

public void setCustomPayload(Map<String,ByteBuffer> customPayload)

toString

public String toString()

Overrides:

toString in class Object

encode

public Envelope encode(ProtocolVersion version)