OperationService (Hazelcast Root 3.2.2 API)

All Known Subinterfaces:

InternalOperationService
```
public interface OperationService
```
The OperationService is responsible for executing operations. A single operation can be executed locally using 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.

Author:

mdogan 12/14/12

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`InvocationBuilder`	`createInvocationBuilder(String serviceName, Operation op, Address target)`
`InvocationBuilder`	`createInvocationBuilder(String serviceName, Operation op, int partitionId)`
`void`	`executeOperation(Operation op)` Executes operation in operation executor pool.
`long`	`getExecutedOperationCount()`
`int`	`getOperationExecutorQueueSize()`
`int`	`getOperationThreadCount()`
`int`	`getPriorityOperationExecutorQueueSize()`
`int`	`getRemoteOperationsCount()`
`int`	`getResponseQueueSize()`
`int`	`getRunningOperationsCount()`
`Map<Integer,Object>`	`invokeOnAllPartitions(String serviceName, OperationFactory operationFactory)` Invokes a set of operation on each partition.
`<E> InternalCompletableFuture<E>`	`invokeOnPartition(String serviceName, Operation op, int partitionId)`
`Map<Integer,Object>`	`invokeOnPartitions(String serviceName, OperationFactory operationFactory, Collection<Integer> partitions)` Invokes an set of operation on selected set of partitions
`<E> InternalCompletableFuture<E>`	`invokeOnTarget(String serviceName, Operation op, Address target)`
`void`	`runOperation(Operation op)` Runs operation in calling thread.
`boolean`	`send(Operation op, Address target)` Executes an operation remotely.
`boolean`	`send(Response response, Address target)`

Method Detail

getResponseQueueSize
```
int getResponseQueueSize()
```

getOperationExecutorQueueSize
```
int getOperationExecutorQueueSize()
```

getPriorityOperationExecutorQueueSize

int getPriorityOperationExecutorQueueSize()

getRunningOperationsCount
```
int getRunningOperationsCount()
```

getRemoteOperationsCount
```
int getRemoteOperationsCount()
```

getOperationThreadCount
```
int getOperationThreadCount()
```

getExecutedOperationCount
```
long getExecutedOperationCount()
```

runOperation
```
void runOperation(Operation op)
```
Runs operation in calling thread.

Parameters:

op - the operation to execute.

executeOperation
```
void executeOperation(Operation op)
```
Executes operation in operation executor pool.

Parameters:

op - the operation to execute.

invokeOnPartition

<E> InternalCompletableFuture<E> invokeOnPartition(String serviceName,
                                                   Operation op,
                                                   int partitionId)

invokeOnTarget

<E> InternalCompletableFuture<E> invokeOnTarget(String serviceName,
                                                Operation op,
                                                Address target)

createInvocationBuilder

InvocationBuilder createInvocationBuilder(String serviceName,
                                          Operation op,
                                          int partitionId)

createInvocationBuilder

InvocationBuilder createInvocationBuilder(String serviceName,
                                          Operation op,
                                          Address target)

invokeOnAllPartitions
```
Map<Integer,Object> invokeOnAllPartitions(String serviceName,
                                          OperationFactory operationFactory)
                                   throws Exception
```
Invokes a set of operation on each partition.

Parameters:

serviceName -

operationFactory - the factory responsible creating operations

Returns:

a Map with partitionId as key and outcome of the operation as value.

Throws:

Exception

invokeOnPartitions

Map<Integer,Object> invokeOnPartitions(String serviceName,
                                       OperationFactory operationFactory,
                                       Collection<Integer> partitions)
                                throws Exception

Invokes an set of operation on selected set of partitions

Parameters:: serviceName -; operationFactory - the factory responsible creating operations; partitions - the partitions the operation should be executed on.
Returns:: a Map with partitionId as key and outcome of the operation as value.
Throws:: Exception

send
```
boolean send(Operation op,
             Address target)
```
Executes an operation remotely. It isn't allowed

Parameters:

op - the operation to send and execute.

target - the address of that target member.

Returns:

send

boolean send(Response response,
             Address target)

Interface OperationService

Method Summary

Method Detail

getResponseQueueSize

getOperationExecutorQueueSize

getPriorityOperationExecutorQueueSize

getRunningOperationsCount

getRemoteOperationsCount

getOperationThreadCount

getExecutedOperationCount

runOperation

executeOperation

invokeOnPartition

invokeOnTarget

createInvocationBuilder

createInvocationBuilder

invokeOnAllPartitions

invokeOnPartitions

send

send