Package org.apache.cassandra.transport

Class SimpleClient

java.lang.Object

org.apache.cassandra.transport.SimpleClient

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

Client

public class SimpleClient
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SimpleClient.Builder
static interface	SimpleClient.EventHandler
static class	SimpleClient.SimpleEventHandler
static class	SimpleClient.SimpleFlusher

Field Summary

Fields

Modifier and Type	Field	Description
protected io.netty.bootstrap.Bootstrap	bootstrap
protected io.netty.channel.Channel	channel
protected String	compression
protected Connection	connection
final String	host
protected io.netty.channel.ChannelFuture	lastWriteFuture
final int	port
protected final org.apache.cassandra.transport.SimpleClient.ResponseHandler	responseHandler
static final int	TIMEOUT_SECONDS
protected final Connection.Tracker	tracker
protected final ProtocolVersion	version

Constructor Summary

Constructors

Constructor	Description
SimpleClient(String host, int port)
SimpleClient(String host, int port, EncryptionOptions encryptionOptions)
SimpleClient(String host, int port, ProtocolVersion version)
SimpleClient(String host, int port, ProtocolVersion version, boolean useBeta, EncryptionOptions encryptionOptions)
SimpleClient(String host, int port, ProtocolVersion version, EncryptionOptions encryptionOptions)

Method Summary

Modifier and Type	Method	Description
static SimpleClient.Builder	builder(String host, int port)
void	close()
SimpleClient	connect(boolean useCompression)
SimpleClient	connect(boolean useCompression, boolean throwOnOverload)
ResultMessage	execute(String query, List<ByteBuffer> values, ConsistencyLevel consistencyLevel)
ResultMessage	execute(String query, ConsistencyLevel consistency)
Map<Message.Request,Message.Response>	execute(List<Message.Request> requests)
Message.Response	execute(Message.Request request)
Message.Response	execute(Message.Request request, boolean throwOnErrorResponse)
ResultMessage	executePrepared(ResultMessage.Prepared prepared, List<ByteBuffer> values, ConsistencyLevel consistency)
ResultMessage.Prepared	prepare(String query)
void	setEventHandler(SimpleClient.EventHandler eventHandler)

Methods inherited from class java.lang.Object

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

Field Details

TIMEOUT_SECONDS

public static final int TIMEOUT_SECONDS

See Also:

• Constant Field Values

host

public final String host

port

public final int port

responseHandler

protected final org.apache.cassandra.transport.SimpleClient.ResponseHandler responseHandler

tracker

protected final Connection.Tracker tracker

version

protected final ProtocolVersion version

connection

protected Connection connection

bootstrap

protected io.netty.bootstrap.Bootstrap bootstrap

channel

protected io.netty.channel.Channel channel

lastWriteFuture

protected io.netty.channel.ChannelFuture lastWriteFuture

compression

protected String compression

Constructor Details

SimpleClient

public SimpleClient(String host,
 int port,
 ProtocolVersion version,
 EncryptionOptions encryptionOptions)

SimpleClient

public SimpleClient(String host,
 int port,
 EncryptionOptions encryptionOptions)

SimpleClient

public SimpleClient(String host,
 int port,
 ProtocolVersion version)

SimpleClient

public SimpleClient(String host,
 int port,
 ProtocolVersion version,
 boolean useBeta,
 EncryptionOptions encryptionOptions)

SimpleClient

public SimpleClient(String host,
 int port)

Method Details

builder

public static SimpleClient.Builder builder(String host,
 int port)

connect

public SimpleClient connect(boolean useCompression)
                     throws IOException

Throws:

IOException

connect

public SimpleClient connect(boolean useCompression,
 boolean throwOnOverload)
                     throws IOException

Throws:

IOException

setEventHandler

public void setEventHandler(SimpleClient.EventHandler eventHandler)

execute

public ResultMessage execute(String query,
 ConsistencyLevel consistency)

execute

public ResultMessage execute(String query,
 List<ByteBuffer> values,
 ConsistencyLevel consistencyLevel)

prepare

public ResultMessage.Prepared prepare(String query)

executePrepared

public ResultMessage executePrepared(ResultMessage.Prepared prepared,
 List<ByteBuffer> values,
 ConsistencyLevel consistency)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

execute

public Message.Response execute(Message.Request request)

execute

public Message.Response execute(Message.Request request,
 boolean throwOnErrorResponse)

execute

public Map<Message.Request,Message.Response> execute(List<Message.Request> requests)