Package org.redisson.command

Class CommandBatchService

java.lang.Object

org.redisson.command.CommandAsyncService

org.redisson.command.CommandBatchService

All Implemented Interfaces:

CommandAsyncExecutor

public class CommandBatchService
extends CommandAsyncService

Author:

Nikita Koksharov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CommandBatchService.ConnectionEntry
static class	CommandBatchService.Entry

Constructor Summary

Constructors

Constructor	Description
CommandBatchService(CommandAsyncExecutor executor)
CommandBatchService(CommandAsyncExecutor executor, BatchOptions options)
CommandBatchService(CommandAsyncExecutor executor, BatchOptions options, RedissonObjectBuilder.ReferenceType referenceType)
CommandBatchService(CommandAsyncExecutor executor, RedissonObjectBuilder.ReferenceType referenceType)

Method Summary

Modifier and Type	Method	Description
void	add(RFuture<?> future, List<CommandBatchService> services)
<V,R> void	async(boolean readOnlyMode, NodeSource nodeSource, Codec codec, RedisCommand<V> command, Object[] params, RPromise<R> mainPromise, boolean ignoreRedirect)
<R> RPromise<R>	createPromise()
void	discard()
RFuture<Void>	discardAsync()
BatchResult<?>	execute()
RFuture<BatchResult<?>>	executeAsync()
RFuture<Void>	executeAsyncVoid()
BatchOptions	getOptions()
protected void	handle(RPromise<Void> mainPromise, AtomicInteger slots, RFuture<?> future)
protected boolean	isEvalCacheActive()
boolean	isExecuted()
protected boolean	isRedisBasedQueue()
protected boolean	isWaitCommand(CommandData<?,?> c)

Methods inherited from class org.redisson.command.CommandAsyncService

convertException, encode, encodeMapKey, encodeMapValue, evalAllAsync, evalReadAsync, evalReadAsync, evalReadAsync, evalWriteAllAsync, evalWriteAsync, evalWriteAsync, get, getConnectionManager, getInterrupted, getObjectBuilder, pollFromAnyAsync, readAllAsync, readAllAsync, readAllAsync, readAllAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readAsync, readBatchedAsync, readRandomAsync, readRandomAsync, syncSubscription, syncSubscriptionInterrupted, writeAllAsync, writeAllAsync, writeAllAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeAsync, writeBatchedAsync

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandBatchService

public CommandBatchService(CommandAsyncExecutor executor)

CommandBatchService

public CommandBatchService(CommandAsyncExecutor executor,
                           RedissonObjectBuilder.ReferenceType referenceType)

CommandBatchService

public CommandBatchService(CommandAsyncExecutor executor,
                           BatchOptions options)

CommandBatchService

public CommandBatchService(CommandAsyncExecutor executor,
                           BatchOptions options,
                           RedissonObjectBuilder.ReferenceType referenceType)

Method Detail

getOptions

public BatchOptions getOptions()

add

public void add(RFuture<?> future,
                List<CommandBatchService> services)

async

public <V,R> void async(boolean readOnlyMode,
                              NodeSource nodeSource,
                              Codec codec,
                              RedisCommand<V> command,
                              Object[] params,
                              RPromise<R> mainPromise,
                              boolean ignoreRedirect)

Overrides:

async in class CommandAsyncService

createPromise

public <R> RPromise<R> createPromise()

Overrides:

createPromise in class CommandAsyncService

discard

public void discard()

discardAsync

public RFuture<Void> discardAsync()

execute

public BatchResult<?> execute()

executeAsyncVoid

public RFuture<Void> executeAsyncVoid()

isExecuted

public boolean isExecuted()

executeAsync

public RFuture<BatchResult<?>> executeAsync()

isRedisBasedQueue

protected boolean isRedisBasedQueue()

isWaitCommand

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

handle

protected void handle(RPromise<Void> mainPromise,
                      AtomicInteger slots,
                      RFuture<?> future)

isEvalCacheActive

protected boolean isEvalCacheActive()

Overrides:

isEvalCacheActive in class CommandAsyncService