Package org.apache.cassandra.cql3

Class QueryEvents

java.lang.Object

org.apache.cassandra.cql3.QueryEvents

public class QueryEvents
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	QueryEvents.Listener

Field Summary

Fields

Modifier and Type	Field	Description
static final QueryEvents	instance

Constructor Summary

Constructors

Constructor	Description
QueryEvents()

Method Summary

Modifier and Type	Method	Description
boolean	hasListeners()
int	listenerCount()
void	notifyBatchFailure(List<QueryHandler.Prepared> prepared, BatchStatement.Type batchType, List<Object> queryOrIdList, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, Exception cause)
void	notifyBatchSuccess(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, long queryTime, Message.Response response)
void	notifyExecuteFailure(QueryHandler.Prepared prepared, QueryOptions options, QueryState state, Exception cause)
void	notifyExecuteSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response)
void	notifyPrepareFailure(CQLStatement statement, String query, QueryState state, Exception cause)
void	notifyPrepareSuccess(Supplier<QueryHandler.Prepared> preparedProvider, String query, QueryState state, long queryTime, ResultMessage.Prepared response)
void	notifyQueryFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause)
void	notifyQuerySuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response)
void	registerListener(QueryEvents.Listener listener)
void	unregisterListener(QueryEvents.Listener listener)

Methods inherited from class java.lang.Object

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

Field Details

instance

public static final QueryEvents instance

Constructor Details

QueryEvents

public QueryEvents()

Method Details

listenerCount

public int listenerCount()

registerListener

public void registerListener(QueryEvents.Listener listener)

unregisterListener

public void unregisterListener(QueryEvents.Listener listener)

notifyQuerySuccess

public void notifyQuerySuccess(CQLStatement statement,
 String query,
 QueryOptions options,
 QueryState state,
 long queryTime,
 Message.Response response)

notifyQueryFailure

public void notifyQueryFailure(CQLStatement statement,
 String query,
 QueryOptions options,
 QueryState state,
 Exception cause)

notifyExecuteSuccess

public void notifyExecuteSuccess(CQLStatement statement,
 String query,
 QueryOptions options,
 QueryState state,
 long queryTime,
 Message.Response response)

notifyExecuteFailure

public void notifyExecuteFailure(QueryHandler.Prepared prepared,
 QueryOptions options,
 QueryState state,
 Exception cause)

notifyBatchSuccess

public void notifyBatchSuccess(BatchStatement.Type batchType,
 List<? extends CQLStatement> statements,
 List<String> queries,
 List<List<ByteBuffer>> values,
 QueryOptions options,
 QueryState state,
 long queryTime,
 Message.Response response)

notifyBatchFailure

public void notifyBatchFailure(List<QueryHandler.Prepared> prepared,
 BatchStatement.Type batchType,
 List<Object> queryOrIdList,
 List<List<ByteBuffer>> values,
 QueryOptions options,
 QueryState state,
 Exception cause)

notifyPrepareSuccess

public void notifyPrepareSuccess(Supplier<QueryHandler.Prepared> preparedProvider,
 String query,
 QueryState state,
 long queryTime,
 ResultMessage.Prepared response)

notifyPrepareFailure

public void notifyPrepareFailure(@Nullable
 CQLStatement statement,
 String query,
 QueryState state,
 Exception cause)

hasListeners

public boolean hasListeners()