org.forgerock.openicf.framework.async.impl

Class GetAsyncApiOpImpl

java.lang.Object

org.forgerock.openicf.framework.async.impl.AbstractAPIOperation

org.forgerock.openicf.framework.async.impl.GetAsyncApiOpImpl

All Implemented Interfaces:

GetAsyncApiOp, APIOperation, GetApiOp

public class GetAsyncApiOpImpl
extends AbstractAPIOperation
implements GetAsyncApiOp

Nested Class Summary

Nested classes/interfaces inherited from class org.forgerock.openicf.framework.async.impl.AbstractAPIOperation

AbstractAPIOperation.ResultBuffer<T,R>

Field Summary

Fields inherited from class org.forgerock.openicf.framework.async.impl.AbstractAPIOperation

FAILED_EXCEPTION

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

NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
GetAsyncApiOpImpl(RequestDistributor<WebSocketConnectionGroup,WebSocketConnectionHolder,RemoteOperationContext> remoteConnection, ConnectorKey connectorKey, org.forgerock.util.Function<RemoteOperationContext,com.google.protobuf.ByteString,RuntimeException> facadeKeyFunction, long timeout)

Method Summary

Modifier and Type	Method and Description
static AbstractLocalOperationProcessor<ConnectorObject,OperationMessages.GetOpRequest>	createProcessor(long requestId, WebSocketConnectionHolder socket, OperationMessages.GetOpRequest message)
ConnectorObject	getObject(ObjectClass objectClass, Uid uid, OperationOptions options) Get a particular ConnectorObject based on the Uid.
org.forgerock.util.promise.Promise<ConnectorObject,RuntimeException>	getObjectAsync(ObjectClass objectClass, Uid uid, OperationOptions options) Get a particular ConnectorObject based on the Uid.

Methods inherited from class org.forgerock.openicf.framework.async.impl.AbstractAPIOperation

asyncTimeout, getConnectorKey, getFacadeKeyFunction, getRemoteConnection, getTimeout, submitRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

GetAsyncApiOpImpl

public GetAsyncApiOpImpl(RequestDistributor<WebSocketConnectionGroup,WebSocketConnectionHolder,RemoteOperationContext> remoteConnection,
                         ConnectorKey connectorKey,
                         org.forgerock.util.Function<RemoteOperationContext,com.google.protobuf.ByteString,RuntimeException> facadeKeyFunction,
                         long timeout)

Method Detail

getObject

public ConnectorObject getObject(ObjectClass objectClass,
                                 Uid uid,
                                 OperationOptions options)

Description copied from interface: GetApiOp

Get a particular ConnectorObject based on the Uid.

Specified by:

getObject in interface GetApiOp

Parameters:

objectClass - type of object to get.

uid - the unique id of the object that to get.

options - additional options that impact the way this operation is run. May be null.

Returns:

ConnectorObject based on the Uid provided or null if no such object could be found.

getObjectAsync

public org.forgerock.util.promise.Promise<ConnectorObject,RuntimeException> getObjectAsync(ObjectClass objectClass,
                                                                                           Uid uid,
                                                                                           OperationOptions options)

Description copied from interface: GetAsyncApiOp

Get a particular ConnectorObject based on the Uid.

Specified by:

getObjectAsync in interface GetAsyncApiOp

Parameters:

objectClass - type of object to get.

uid - the unique id of the object that to get.

options - additional options that impact the way this operation is run. May be null.

Returns:

ConnectorObject based on the Uid provided or null if no such object could be found.

createProcessor

public static AbstractLocalOperationProcessor<ConnectorObject,OperationMessages.GetOpRequest> createProcessor(long requestId,
                                                                                                              WebSocketConnectionHolder socket,
                                                                                                              OperationMessages.GetOpRequest message)