org.forgerock.openicf.framework.async.impl

Class AbstractAPIOperation

java.lang.Object

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

Direct Known Subclasses:

AuthenticationAsyncApiOpImpl, BatchApiOpImpl, ConnectorEventSubscriptionApiOpImpl, CreateAsyncApiOpImpl, DeleteAsyncApiOpImpl, GetAsyncApiOpImpl, ResolveUsernameAsyncApiOpImpl, SchemaAsyncApiOpImpl, ScriptOnConnectorAsyncApiOpImpl, ScriptOnResourceAsyncApiOpImpl, SearchAsyncApiOpImpl, SyncAsyncApiOpImpl, SyncEventSubscriptionApiOpImpl, TestAsyncApiOpImpl, UpdateAsyncApiOpImpl, ValidateAsyncApiOpImpl

public abstract class AbstractAPIOperation
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractAPIOperation.ResultBuffer<T,R>

Field Summary

Fields

Modifier and Type	Field and Description
static ConnectionFailedException	FAILED_EXCEPTION

Constructor Summary

Constructors

Constructor and Description
AbstractAPIOperation(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
protected <T> T	asyncTimeout(org.forgerock.util.promise.Promise<T,RuntimeException> promise)
ConnectorKey	getConnectorKey()
protected org.forgerock.util.Function<RemoteOperationContext,com.google.protobuf.ByteString,RuntimeException>	getFacadeKeyFunction()
protected RequestDistributor<WebSocketConnectionGroup,WebSocketConnectionHolder,RemoteOperationContext>	getRemoteConnection()
protected long	getTimeout()
protected <V,M extends com.google.protobuf.MessageLite,R extends AbstractRemoteOperationRequestFactory.AbstractRemoteOperationRequest<V,M>> org.forgerock.util.promise.Promise<V,RuntimeException>	submitRequest(AbstractRemoteOperationRequestFactory<V,R> requestFactory)

Methods inherited from class java.lang.Object

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

Field Detail

FAILED_EXCEPTION

public static final ConnectionFailedException FAILED_EXCEPTION

Constructor Detail

AbstractAPIOperation

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

Method Detail

getConnectorKey

public ConnectorKey getConnectorKey()

getTimeout

protected long getTimeout()

getRemoteConnection

protected RequestDistributor<WebSocketConnectionGroup,WebSocketConnectionHolder,RemoteOperationContext> getRemoteConnection()

getFacadeKeyFunction

protected org.forgerock.util.Function<RemoteOperationContext,com.google.protobuf.ByteString,RuntimeException> getFacadeKeyFunction()

submitRequest

protected <V,M extends com.google.protobuf.MessageLite,R extends AbstractRemoteOperationRequestFactory.AbstractRemoteOperationRequest<V,M>> org.forgerock.util.promise.Promise<V,RuntimeException> submitRequest(AbstractRemoteOperationRequestFactory<V,R> requestFactory)

asyncTimeout

protected <T> T asyncTimeout(org.forgerock.util.promise.Promise<T,RuntimeException> promise)