org.identityconnectors.framework.impl.api.local.operations

Class BatchImpl

java.lang.Object

org.identityconnectors.framework.impl.api.local.operations.APIOperationRunner

org.identityconnectors.framework.impl.api.local.operations.ConnectorAPIOperationRunner

org.identityconnectors.framework.impl.api.local.operations.BatchImpl

All Implemented Interfaces:

APIOperation, BatchApiOp

public class BatchImpl
extends ConnectorAPIOperationRunner
implements BatchApiOp

Field Summary

Fields inherited from interface org.identityconnectors.framework.api.operations.APIOperation

NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
BatchImpl(ConnectorOperationalContext context, Connector connector) Construct a batch operation.
BatchImpl(ConnectorOperationalContext context, Connector connector, LocalConnectorFacadeImpl.ReferenceCounter referenceCounter) Construct a batch operation.

Method Summary

Modifier and Type	Method and Description
Subscription	executeBatch(List<BatchTask> tasks, Observer<BatchResult> observer, OperationOptions options)
Subscription	queryBatch(BatchToken batchToken, Observer<BatchResult> observer, OperationOptions options)

Methods inherited from class org.identityconnectors.framework.impl.api.local.operations.ConnectorAPIOperationRunner

getConnector, getNormalizer, getOperationalContext

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchImpl

public BatchImpl(ConnectorOperationalContext context,
                 Connector connector)

Construct a batch operation.

Parameters:

context - the context for the connector operation.

connector - the connector on which to execute the operation.

BatchImpl

public BatchImpl(ConnectorOperationalContext context,
                 Connector connector,
                 LocalConnectorFacadeImpl.ReferenceCounter referenceCounter)

Construct a batch operation.

Parameters:

context - the context for the connector operation.

connector - the connector on which to execute the operation.

Method Detail

executeBatch

public Subscription executeBatch(List<BatchTask> tasks,
                                 Observer<BatchResult> observer,
                                 OperationOptions options)

Specified by:

executeBatch in interface BatchApiOp

Parameters:

tasks - the list of batch tasks to execute.

observer - an observer/handler for the ongoing results of the batch.

options - options for the operation.

Returns:

a subscription object for managing the lifecycle of the observer.

queryBatch

public Subscription queryBatch(BatchToken batchToken,
                               Observer<BatchResult> observer,
                               OperationOptions options)

Specified by:

queryBatch in interface BatchApiOp

Parameters:

batchToken - a token for a previously started batch, the ongoing results of which should invoke the observer.

observer - an observer/handler for the ongoing results of the batch.

options - options for the operation.

Returns:

a subscription object for managing the lifecycle of the observer.