com.basho.riak.client.core.operations

Class PBFutureOperation<T,U,S>

java.lang.Object

com.basho.riak.client.core.FutureOperation<T,U,S>

com.basho.riak.client.core.operations.PBFutureOperation<T,U,S>

Type Parameters:

T - The type the operation returns

U - The protocol type returned

S - Query info type

All Implemented Interfaces:

RiakFuture<T,S>, Future<T>

Direct Known Subclasses:

DeleteOperation, DescribeTableOperation, FetchOperation, ListKeysOperation, QueryOperation, StoreOperation

public abstract class PBFutureOperation<T,U,S>
extends FutureOperation<T,U,S>

An abstract PB operation that introduces generic encoding/decoding

Since:

2.0.3

Author:

Sergey Galkin , Alex Moore

Field Summary

Fields

Modifier and Type	Field and Description
protected com.google.protobuf.GeneratedMessage.Builder<?>	reqBuilder

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PBFutureOperation(byte reqMessageCode, byte respMessageCode, com.google.protobuf.GeneratedMessage.Builder<?> reqBuilder, com.google.protobuf.Parser<U> respParser)

Method Summary

Modifier and Type	Method and Description
protected U	checkAndGetSingleResponse(List<U> responses)
protected RiakMessage	createChannelMessage()
protected U	decode(RiakMessage rawMessage)

Methods inherited from class com.basho.riak.client.core.FutureOperation

addListener, await, await, cancel, cause, channelMessage, convert, done, get, get, getNow, getQueryInfo, isCancelled, isDone, isSuccess, removeListener, setResponse

Methods inherited from class java.lang.Object

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

Field Detail

reqBuilder

protected final com.google.protobuf.GeneratedMessage.Builder<?> reqBuilder

Constructor Detail

PBFutureOperation

protected PBFutureOperation(byte reqMessageCode,
                            byte respMessageCode,
                            com.google.protobuf.GeneratedMessage.Builder<?> reqBuilder,
                            com.google.protobuf.Parser<U> respParser)

Method Detail

createChannelMessage

protected RiakMessage createChannelMessage()

Specified by:

createChannelMessage in class FutureOperation<T,U,S>

decode

protected U decode(RiakMessage rawMessage)

Specified by:

decode in class FutureOperation<T,U,S>

checkAndGetSingleResponse

protected U checkAndGetSingleResponse(List<U> responses)