com.gigaspaces.internal.client.spaceproxy.actions

Class AbstractSpaceProxyActionManager<TSpaceProxy extends ISpaceProxy>

java.lang.Object

com.gigaspaces.internal.client.spaceproxy.actions.AbstractSpaceProxyActionManager<TSpaceProxy>

Direct Known Subclasses:

LocalCacheImplActionManager, LocalViewImplActionManager, SpaceProxyImplActionManager

public abstract class AbstractSpaceProxyActionManager<TSpaceProxy extends ISpaceProxy>
extends Object

An action manager, holding all the action listeners used by different space proxies.

Author:

GigaSpaces

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSpaceProxyActionManager(TSpaceProxy spaceProxy)

Method Summary

Modifier and Type	Method and Description
AggregationResult	aggregate(Object query, AggregationSet aggregationSet, Transaction txn, int modifiers)
AsyncFuture<AddTypeIndexesResult>	asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener)
<T> Future<ChangeResult<T>>	asyncChange(Object template, ChangeSet changeSet, Transaction txn, long timeout, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener)
AsyncFuture<?>	asyncRead(Object template, Transaction txn, long timeout, int modifiers, AsyncFutureListener<?> listener)
AsyncFuture<?>	asyncTake(Object template, Transaction txn, long timeout, int modifiers, AsyncFutureListener<?> listener)
<T> ChangeResult<T>	change(Object template, ChangeSet changeSet, Transaction txn, long timeout, ChangeModifiers modifiers)
int	clear(Object template, Transaction txn, int modifiers)
int	count(Object template, Transaction txn, int modifiers)
protected abstract AdminProxyAction<TSpaceProxy>	createAdminProxyAction()
protected abstract AggregateProxyAction<TSpaceProxy>	createAggregateAction()
protected abstract ChangeProxyAction<TSpaceProxy>	createChangeProxyAction()
protected abstract CountClearProxyAction<TSpaceProxy>	createCountClearProxyAction()
protected abstract ReadTakeByIdsProxyAction<TSpaceProxy>	createReadTakeByIdsProxyAction()
protected abstract ReadTakeEntriesUidsProxyAction<TSpaceProxy>	createReadTakeEntriesUidsProxyAction()
protected abstract ReadTakeMultipleProxyAction<TSpaceProxy>	createReadTakeMultipleProxyAction()
protected abstract ReadTakeProxyAction<TSpaceProxy>	createReadTakeProxyAction()
protected abstract SnapshotProxyAction<TSpaceProxy>	createSnapshotProxyAction()
protected abstract TypeDescriptorActionsProxyExecutor<TSpaceProxy>	createTypeDescriptorActionsExecutor()
protected abstract WriteProxyAction<TSpaceProxy>	createWriteProxyAction()
void	dropClass(String className)
AsyncFuture	executeTask(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener)
SpaceHealthStatus	getSpaceHealthStatus()
ITypeDesc	getTypeDescriptor(String typeName)
void	ping()
Object	read(Object template, Transaction txn, long timeout, int modifiers, boolean ifExists)
Object	read(ReadTakeProxyActionInfo actionInfo)
Object	readById(String className, Object id, Object routing, Transaction txn, long timeout, int modifiers, boolean ifExists, QueryResultTypeInternal resultType, String[] projections)
Object[]	readByIds(ReadTakeByIdsProxyActionInfo actionInfo, boolean returnPackets)
Object[]	readByIds(String className, Object[] ids, Object[] routings, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections)
Object[]	readByIds(String className, Object[] ids, Object routing, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections)
Object	readByUid(String uid, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPacket)
ReadTakeEntriesUidsResult	readEntriesUids(ITemplatePacket template, Transaction transaction, int entriesLimit, int modifiers)
Object[]	readMultiple(Object template, Transaction txn, long timeout, int maxEntries, int minEntriesToWaitFor, int modifiers, boolean returnOnlyUids, boolean ifExist)
ITypeDesc	registerTypeDescriptor(Class<?> type)
void	registerTypeDescriptor(ITypeDesc typeDesc)
<T> ISpaceQuery<T>	snapshot(Object object)
Object	take(Object template, Transaction txn, long timeout, int modifiers, boolean ifExists)
Object	take(ReadTakeProxyActionInfo actionInfo)
Object	takeById(String className, Object id, Object routing, int version, Transaction txn, long timeout, int modifiers, boolean ifExists, QueryResultTypeInternal resultType, String[] projections)
Object[]	takeByIds(ReadTakeByIdsProxyActionInfo actionInfo, boolean returnPackets)
Object[]	takeByIds(String className, Object[] ids, Object[] routings, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections)
Object[]	takeByIds(String className, Object[] ids, Object routing, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections)
Object	takeByUid(String uid, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPacket)
Object[]	takeMultiple(Object template, Transaction txn, long timeout, int maxEntries, int minEntriesToWaitFor, int modifiers, boolean returnOnlyUids, boolean ifExist)
void	unregisterTypeDescriptor(String typeName)
LeaseContext<?>	write(Object entry, Transaction txn, long lease, long timeout, int modifiers)
LeaseContext<?>[]	writeMultiple(Object[] objects, Transaction txn, long lease, long[] leases, long timeout, int modifiers)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSpaceProxyActionManager

protected AbstractSpaceProxyActionManager(TSpaceProxy spaceProxy)

Method Detail

getTypeDescriptor

public ITypeDesc getTypeDescriptor(String typeName)
                            throws RemoteException

Throws:

RemoteException

registerTypeDescriptor

public void registerTypeDescriptor(ITypeDesc typeDesc)
                            throws RemoteException

Throws:

RemoteException

registerTypeDescriptor

public ITypeDesc registerTypeDescriptor(Class<?> type)
                                 throws RemoteException

Throws:

RemoteException

asyncAddIndexes

public AsyncFuture<AddTypeIndexesResult> asyncAddIndexes(String typeName,
                                                         SpaceIndex[] indexes,
                                                         AsyncFutureListener<AddTypeIndexesResult> listener)
                                                  throws RemoteException

Throws:

RemoteException

dropClass

public void dropClass(String className)
               throws RemoteException,
                      DropClassException

Throws:

RemoteException

DropClassException

unregisterTypeDescriptor

public void unregisterTypeDescriptor(String typeName)
                              throws RemoteException

Throws:

RemoteException

clear

public int clear(Object template,
                 Transaction txn,
                 int modifiers)
          throws ClearException

Throws:

ClearException

count

public int count(Object template,
                 Transaction txn,
                 int modifiers)
          throws RemoteException,
                 TransactionException,
                 UnusableEntryException

Throws:

RemoteException

TransactionException

UnusableEntryException

executeTask

public AsyncFuture executeTask(SpaceTask task,
                               Object routing,
                               Transaction tx,
                               AsyncFutureListener listener)
                        throws RemoteException,
                               TransactionException

Throws:

RemoteException

TransactionException

ping

public void ping()
          throws RemoteException

Throws:

RemoteException

getSpaceHealthStatus

public SpaceHealthStatus getSpaceHealthStatus()
                                       throws RemoteException

Throws:

RemoteException

read

public Object read(Object template,
                   Transaction txn,
                   long timeout,
                   int modifiers,
                   boolean ifExists)
            throws UnusableEntryException,
                   TransactionException,
                   InterruptedException,
                   RemoteException

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

readById

public Object readById(String className,
                       Object id,
                       Object routing,
                       Transaction txn,
                       long timeout,
                       int modifiers,
                       boolean ifExists,
                       QueryResultTypeInternal resultType,
                       String[] projections)
                throws RemoteException,
                       UnusableEntryException,
                       TransactionException,
                       InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

readByUid

public Object readByUid(String uid,
                        Transaction txn,
                        int modifiers,
                        QueryResultTypeInternal resultType,
                        boolean returnPacket)
                 throws RemoteException,
                        UnusableEntryException,
                        TransactionException,
                        InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

read

public Object read(ReadTakeProxyActionInfo actionInfo)
            throws UnusableEntryException,
                   TransactionException,
                   InterruptedException,
                   RemoteException

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

asyncRead

public AsyncFuture<?> asyncRead(Object template,
                                Transaction txn,
                                long timeout,
                                int modifiers,
                                AsyncFutureListener<?> listener)
                         throws RemoteException

Throws:

RemoteException

readMultiple

public Object[] readMultiple(Object template,
                             Transaction txn,
                             long timeout,
                             int maxEntries,
                             int minEntriesToWaitFor,
                             int modifiers,
                             boolean returnOnlyUids,
                             boolean ifExist)
                      throws TransactionException,
                             UnusableEntryException,
                             RemoteException

Throws:

TransactionException

UnusableEntryException

RemoteException

readByIds

public Object[] readByIds(String className,
                          Object[] ids,
                          Object routing,
                          Transaction txn,
                          int modifiers,
                          QueryResultTypeInternal resultType,
                          boolean returnPackets,
                          String[] projections)
                   throws RemoteException,
                          UnusableEntryException,
                          TransactionException,
                          InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

readByIds

public Object[] readByIds(String className,
                          Object[] ids,
                          Object[] routings,
                          Transaction txn,
                          int modifiers,
                          QueryResultTypeInternal resultType,
                          boolean returnPackets,
                          String[] projections)
                   throws RemoteException,
                          UnusableEntryException,
                          TransactionException,
                          InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

readByIds

public Object[] readByIds(ReadTakeByIdsProxyActionInfo actionInfo,
                          boolean returnPackets)
                   throws RemoteException,
                          TransactionException,
                          InterruptedException,
                          UnusableEntryException

Throws:

RemoteException

TransactionException

InterruptedException

UnusableEntryException

readEntriesUids

public ReadTakeEntriesUidsResult readEntriesUids(ITemplatePacket template,
                                                 Transaction transaction,
                                                 int entriesLimit,
                                                 int modifiers)
                                          throws RemoteException,
                                                 TransactionException,
                                                 UnusableEntryException

Throws:

RemoteException

TransactionException

UnusableEntryException

takeByIds

public Object[] takeByIds(String className,
                          Object[] ids,
                          Object routing,
                          Transaction txn,
                          int modifiers,
                          QueryResultTypeInternal resultType,
                          boolean returnPackets,
                          String[] projections)
                   throws RemoteException,
                          UnusableEntryException,
                          TransactionException,
                          InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

takeByIds

public Object[] takeByIds(String className,
                          Object[] ids,
                          Object[] routings,
                          Transaction txn,
                          int modifiers,
                          QueryResultTypeInternal resultType,
                          boolean returnPackets,
                          String[] projections)
                   throws RemoteException,
                          UnusableEntryException,
                          TransactionException,
                          InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

takeByIds

public Object[] takeByIds(ReadTakeByIdsProxyActionInfo actionInfo,
                          boolean returnPackets)
                   throws RemoteException,
                          TransactionException,
                          InterruptedException,
                          UnusableEntryException

Throws:

RemoteException

TransactionException

InterruptedException

UnusableEntryException

snapshot

public <T> ISpaceQuery<T> snapshot(Object object)
                            throws RemoteException

Throws:

RemoteException

take

public Object take(Object template,
                   Transaction txn,
                   long timeout,
                   int modifiers,
                   boolean ifExists)
            throws UnusableEntryException,
                   TransactionException,
                   InterruptedException,
                   RemoteException

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

takeById

public Object takeById(String className,
                       Object id,
                       Object routing,
                       int version,
                       Transaction txn,
                       long timeout,
                       int modifiers,
                       boolean ifExists,
                       QueryResultTypeInternal resultType,
                       String[] projections)
                throws RemoteException,
                       UnusableEntryException,
                       TransactionException,
                       InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

takeByUid

public Object takeByUid(String uid,
                        Transaction txn,
                        int modifiers,
                        QueryResultTypeInternal resultType,
                        boolean returnPacket)
                 throws RemoteException,
                        UnusableEntryException,
                        TransactionException,
                        InterruptedException

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

take

public Object take(ReadTakeProxyActionInfo actionInfo)
            throws UnusableEntryException,
                   TransactionException,
                   InterruptedException,
                   RemoteException

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

asyncTake

public AsyncFuture<?> asyncTake(Object template,
                                Transaction txn,
                                long timeout,
                                int modifiers,
                                AsyncFutureListener<?> listener)
                         throws RemoteException

Throws:

RemoteException

takeMultiple

public Object[] takeMultiple(Object template,
                             Transaction txn,
                             long timeout,
                             int maxEntries,
                             int minEntriesToWaitFor,
                             int modifiers,
                             boolean returnOnlyUids,
                             boolean ifExist)
                      throws TransactionException,
                             UnusableEntryException,
                             RemoteException

Throws:

TransactionException

UnusableEntryException

RemoteException

write

public LeaseContext<?> write(Object entry,
                             Transaction txn,
                             long lease,
                             long timeout,
                             int modifiers)
                      throws TransactionException,
                             RemoteException

Throws:

TransactionException

RemoteException

writeMultiple

public LeaseContext<?>[] writeMultiple(Object[] objects,
                                       Transaction txn,
                                       long lease,
                                       long[] leases,
                                       long timeout,
                                       int modifiers)
                                throws TransactionException,
                                       RemoteException

Throws:

TransactionException

RemoteException

change

public <T> ChangeResult<T> change(Object template,
                                  ChangeSet changeSet,
                                  Transaction txn,
                                  long timeout,
                                  ChangeModifiers modifiers)
                           throws RemoteException,
                                  TransactionException

Throws:

RemoteException

TransactionException

asyncChange

public <T> Future<ChangeResult<T>> asyncChange(Object template,
                                               ChangeSet changeSet,
                                               Transaction txn,
                                               long timeout,
                                               ChangeModifiers modifiers,
                                               AsyncFutureListener<ChangeResult<T>> listener)
                                        throws RemoteException

Throws:

RemoteException

aggregate

public AggregationResult aggregate(Object query,
                                   AggregationSet aggregationSet,
                                   Transaction txn,
                                   int modifiers)
                            throws RemoteException,
                                   TransactionException,
                                   InterruptedException

Throws:

RemoteException

TransactionException

InterruptedException

createTypeDescriptorActionsExecutor

protected abstract TypeDescriptorActionsProxyExecutor<TSpaceProxy> createTypeDescriptorActionsExecutor()

createAdminProxyAction

protected abstract AdminProxyAction<TSpaceProxy> createAdminProxyAction()

createCountClearProxyAction

protected abstract CountClearProxyAction<TSpaceProxy> createCountClearProxyAction()

createReadTakeProxyAction

protected abstract ReadTakeProxyAction<TSpaceProxy> createReadTakeProxyAction()

createReadTakeMultipleProxyAction

protected abstract ReadTakeMultipleProxyAction<TSpaceProxy> createReadTakeMultipleProxyAction()

createReadTakeByIdsProxyAction

protected abstract ReadTakeByIdsProxyAction<TSpaceProxy> createReadTakeByIdsProxyAction()

createReadTakeEntriesUidsProxyAction

protected abstract ReadTakeEntriesUidsProxyAction<TSpaceProxy> createReadTakeEntriesUidsProxyAction()

createSnapshotProxyAction

protected abstract SnapshotProxyAction<TSpaceProxy> createSnapshotProxyAction()

createWriteProxyAction

protected abstract WriteProxyAction<TSpaceProxy> createWriteProxyAction()

createChangeProxyAction

protected abstract ChangeProxyAction<TSpaceProxy> createChangeProxyAction()

createAggregateAction

protected abstract AggregateProxyAction<TSpaceProxy> createAggregateAction()