com.basho.riak.client.core.operations

Class TTBFutureOperation<T,S>

java.lang.Object

com.basho.riak.client.core.FutureOperation<T,byte[],S>

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

Type Parameters:

T - The type the operation returns

S - Query info type

All Implemented Interfaces:

RiakFuture<T,S>, Future<T>

Direct Known Subclasses:

FetchOperation, QueryOperation, StoreOperation

public abstract class TTBFutureOperation<T,S>
extends FutureOperation<T,byte[],S>

An abstract TTB operation that introduces generic encoding/decoding

Since:

2.0.6

Author:

Alex Moore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TTBFutureOperation.TTBEncoder
static interface	TTBFutureOperation.TTBParser<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected byte	reqMessageCode
protected TTBFutureOperation.TTBEncoder	requestBuilder
protected byte	respMessageCode
protected TTBFutureOperation.TTBParser<T>	responseParser

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TTBFutureOperation(TTBFutureOperation.TTBEncoder requestBuilder, TTBFutureOperation.TTBParser<T> responseParser)

Method Summary

Modifier and Type	Method and Description
protected RiakMessage	createChannelMessage()
protected byte[]	decode(RiakMessage rawMessage)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

reqMessageCode

protected final byte reqMessageCode

See Also:

Constant Field Values

respMessageCode

protected final byte respMessageCode

See Also:

Constant Field Values

requestBuilder

protected final TTBFutureOperation.TTBEncoder requestBuilder

responseParser

protected final TTBFutureOperation.TTBParser<T> responseParser

Constructor Detail

TTBFutureOperation

protected TTBFutureOperation(TTBFutureOperation.TTBEncoder requestBuilder,
                             TTBFutureOperation.TTBParser<T> responseParser)

Method Detail

createChannelMessage

protected RiakMessage createChannelMessage()

Specified by:

createChannelMessage in class FutureOperation<T,byte[],S>

decode

protected byte[] decode(RiakMessage rawMessage)

Specified by:

decode in class FutureOperation<T,byte[],S>