public interface OperationService
runOperation(Operation)
and executeOperation(Operation)
.
Or it can executed remotely using the one of the send methods.
It also is possible to execute multiple operation one multiple partitions using one of the invoke methods.int getResponseQueueSize()
int getOperationExecutorQueueSize()
int getPriorityOperationExecutorQueueSize()
int getRunningOperationsCount()
int getRemoteOperationsCount()
int getOperationThreadCount()
long getExecutedOperationCount()
void runOperation(Operation op)
op
- the operation to execute.void executeOperation(Operation op)
op
- the operation to execute.<E> InternalCompletableFuture<E> invokeOnPartition(String serviceName, Operation op, int partitionId)
<E> InternalCompletableFuture<E> invokeOnTarget(String serviceName, Operation op, Address target)
InvocationBuilder createInvocationBuilder(String serviceName, Operation op, int partitionId)
InvocationBuilder createInvocationBuilder(String serviceName, Operation op, Address target)
Map<Integer,Object> invokeOnAllPartitions(String serviceName, OperationFactory operationFactory) throws Exception
serviceName
- operationFactory
- the factory responsible creating operationsException
Map<Integer,Object> invokeOnPartitions(String serviceName, OperationFactory operationFactory, Collection<Integer> partitions) throws Exception
serviceName
- operationFactory
- the factory responsible creating operationspartitions
- the partitions the operation should be executed on.Exception
boolean send(Operation op, Address target)
op
- the operation to send and execute.target
- the address of that target member.Copyright © 2014 Hazelcast, Inc.. All rights reserved.