Package org.redisson.client.protocol

Class CommandData<T,R>

org.redisson.client.protocol.CommandData<T,R>

Type Parameters:

T - input type

R - output type

All Implemented Interfaces:

QueueCommand

Direct Known Subclasses:

BatchCommandData

public class CommandData<T,R>
extends 
implements QueueCommand

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
CommandData(RPromise<R> promise, Codec codec, RedisCommand<T> command, [] params)
CommandData(RPromise<R> promise, > messageDecoder, Codec codec, RedisCommand<T> command, [] params)

Method Summary

Modifier and Type	Method	Description
	cause()
Codec	getCodec()
RedisCommand<T>	getCommand()
>	getMessageDecoder()
[]	getParams()
RPromise<R>	getPromise()
<,>>	getPubSubOperations()
boolean	isBlockingCommand()
boolean	isExecuted()
boolean	isSuccess()
	toString()
boolean	cause)

Methods inherited from class java.lang.

, , , , , , , , ,

Constructor Detail

CommandData

public CommandData(RPromise<R> promise,
                   Codec codec,
                   RedisCommand<T> command,
                   [] params)

CommandData

public CommandData(RPromise<R> promise,
                   > messageDecoder,
                   Codec codec,
                   RedisCommand<T> command,
                   [] params)

Method Detail

getCommand

public RedisCommand<T> getCommand()

getParams

public [] getParams()

getMessageDecoder

public > getMessageDecoder()

getPromise

public RPromise<R> getPromise()

cause

public  cause()

isSuccess

public boolean isSuccess()

tryFailure

public boolean tryFailure( cause)

Specified by:

tryFailure in interface QueueCommand

getCodec

public Codec getCodec()

toString

public  toString()

Overrides:

in class

getPubSubOperations

public <,>> getPubSubOperations()

Specified by:

getPubSubOperations in interface QueueCommand

isBlockingCommand

public boolean isBlockingCommand()

Specified by:

isBlockingCommand in interface QueueCommand

isExecuted

public boolean isExecuted()

Specified by:

isExecuted in interface QueueCommand