Package org.redisson.command

Class RedisCommonBatchExecutor

,>

org.redisson.command.RedisCommonBatchExecutor

public class RedisCommonBatchExecutor
extends ,>

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
RedisCommonBatchExecutor(NodeSource source, > mainPromise, ConnectionManager connectionManager, BatchOptions options, CommandBatchService.Entry entry, slots, RedissonObjectBuilder.ReferenceType referenceType)

Method Summary

Modifier and Type	Method	Description
protected void	free()
protected void	> attemptPromise, RFuture<RedisConnection> connectionFuture)
protected boolean	isWaitCommand(CommandData<?,?> c)
protected void	onException()
protected void	> attemptPromise, RedisConnection connection)

Methods inherited from class org.redisson.command.RedisExecutor

checkAttemptPromise, convertException, execute, free, getCodec, getConnection, getRedisClient, handleError, handleSuccess, isResendAllowed, releaseConnection

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Detail

RedisCommonBatchExecutor

public RedisCommonBatchExecutor(NodeSource source,
                                > mainPromise,
                                ConnectionManager connectionManager,
                                BatchOptions options,
                                CommandBatchService.Entry entry,
                                 slots,
                                RedissonObjectBuilder.ReferenceType referenceType)

Method Detail

onException

protected void onException()

Overrides:

,>

free

protected void free()

Overrides:

,>

sendCommand

protected void sendCommand(> attemptPromise,
                           RedisConnection connection)

Overrides:

,>

isWaitCommand

protected boolean isWaitCommand(CommandData<?,?> c)

handleResult

protected void handleResult(> attemptPromise,
                            RFuture<RedisConnection> connectionFuture)
                     throws 

Overrides:

,>

Throws: