com.gigaspaces.internal.client.spaceproxy

Class AbstractSpaceProxy

java.lang.Object

com.gigaspaces.internal.client.spaceproxy.AbstractSpaceProxy

All Implemented Interfaces:

IPojoSpace, ISpaceProxy, SecuredService, IDotnetProxyAssociated, ActionMaker, IJSpace, JavaSpace

Direct Known Subclasses:

AbstractDirectSpaceProxy, AbstractSpaceCacheContainer

public abstract class AbstractSpaceProxy
extends Object
implements ISpaceProxy

A common base class for most space proxies.

Implements all the space operations and calling the appropriate Listener using the AbstractSpaceProxyActionManager. Extended classes should initialize the listeners in the action manager.

Author:

GigaSpaces

Field Summary

Fields inherited from interface com.j_spaces.core.IJSpace

NO_WAIT

Fields inherited from interface net.jini.space.JavaSpace

NO_WAIT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSpaceProxy()

Method Summary

Modifier and Type	Method and Description
AggregationResult	aggregate(Object template, AggregationSet aggregationSet, Transaction txn, int readModifiers)
void	applyNotifyInfoDefaults(NotifyInfo notifyInfo)
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) Internal methods only.
AsyncFuture<?>	asyncTake(Object template, Transaction txn, long timeout, int modifiers, AsyncFutureListener listener) Internal methods only.
<T> ChangeResult<T>	change(Object template, ChangeSet changeSet, Transaction txn, long timeout, ChangeModifiers modifiers) Change entry in space
boolean	checkIfConnected()
void	clear(Object template, Transaction txn)
int	clear(Object template, Transaction txn, int modifiers)
int	count(Object template, Transaction txn)
int	count(Object template, Transaction txn, int modifiers)
protected abstract AbstractSpaceProxyActionManager<?>	createActionManager()
void	dropClass(String className) Drops all Class's entries and all its templates from this Space instance.
AsyncFuture	execute(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener) Executes a task on a single space.
int	getAppDomainId()
String	getContainerName()
long	getDotnetProxyHandleId()
IDirectSpaceProxy	getLocalSpace()
IDirectSpaceProxy	getRemoteSpace()
SpaceHealthStatus	getSpaceHealthStatus() Gets an object representing the space health status
ITypeDesc	getTypeDescriptor(String typeName)
boolean	hasAssociatedAppDomain()
boolean	isCacheContainer()
boolean	isLocalCacheCacheContainer()
boolean	isLocalViewContainer()
boolean	isTargetOfADotnetProxy()
EventRegistration	notify(Entry template, Transaction txn, RemoteEventListener listener, long lease, MarshalledObject handback) When entries are written that match this template notify the given listener with a RemoteEvent that includes the handback object.
void	ping() Checks whether the space is alive and accessible.
Entry	read(Entry template, Transaction txn, long timeout) Read any matching entry from the space, blocking until one exists.
Object	read(Object template, Transaction txn, long timeout)
Object	read(Object template, Transaction txn, long timeout, int modifiers)
Object	read(Object template, Transaction txn, long timeout, int modifiers, boolean ifExists)
Object	readById(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) Read entries UIDs from space.
Entry	readIfExists(Entry template, Transaction txn, long timeout) Read any matching entry from the space, returning null if there is currently is none.
Object	readIfExists(Object template, Transaction txn, long timeout)
Object	readIfExists(Object template, Transaction txn, long timeout, int modifiers)
Object[]	readMultiple(Object template, Transaction txn, int maxEntries)
Object[]	readMultiple(Object template, Transaction txn, int maxEntries, int modifiers)
Object[]	readMultiple(Object template, Transaction txn, int maxEntries, int modifiers, boolean returnOnlyUids)
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)
void	setAppDomainId(int appDomainId) associate this object to the specified AppDomain id
void	setDotnetProxyHandleId(long handleId) Sets a dotnet proxy handle id
Entry	snapshot(Entry e) The process of serializing an entry for transmission to a JavaSpaces service will be identical if the same entry is used twice.
<T> ISpaceQuery<T>	snapshot(Object template)
Entry	take(Entry template, Transaction txn, long timeout) Take a matching entry from the space, waiting until one exists.
Object	take(Object template, Transaction txn, long timeout)
Object	take(Object template, Transaction txn, long timeout, int modifiers)
Object	take(Object template, Transaction txn, long timeout, int modifiers, boolean ifExists)
Object	takeById(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)
Entry	takeIfExists(Entry template, Transaction txn, long timeout) Take a matching entry from the space, returning null if there is currently is none.
Object	takeIfExists(Object template, Transaction txn, long timeout)
Object	takeIfExists(Object template, Transaction txn, long timeout, int modifiers)
Object[]	takeMultiple(Object template, Transaction txn, int maxEntries)
Object[]	takeMultiple(Object template, Transaction txn, int maxEntries, int modifiers)
Object[]	takeMultiple(Object template, Transaction txn, int maxEntries, int modifiers, boolean returnOnlyUids)
Object[]	takeMultiple(Object template, Transaction txn, long timeout, int maxEntries, int minEntriesToWaitFor, int modifiers, boolean returnOnlyUids, boolean ifExist)
void	unregisterTypeDescriptor(String typeName)
Object	update(Object updatedEntry, Transaction transaction, long lease, long timeout)
Object	update(Object entry, Transaction txn, long lease, long timeout, int modifiers)
Object[]	updateMultiple(Object[] entries, Transaction txn, long[] leases)
Object[]	updateMultiple(Object[] entries, Transaction txn, long[] leases, int modifiers)
Lease	write(Entry entry, Transaction txn, long lease) Write a new entry into the space.
LeaseContext<?>	write(Object entry, Transaction txn, long lease)
LeaseContext<?>	write(Object entry, Transaction txn, long lease, long timeout, int modifiers)
LeaseContext<?>[]	writeMultiple(Object[] objects, Transaction txn, long lease)
LeaseContext<?>[]	writeMultiple(Object[] objects, Transaction txn, long[] leases, int modifiers)
LeaseContext<?>[]	writeMultiple(Object[] objects, Transaction txn, long lease, int modifiers)
LeaseContext<?>[]	writeMultiple(Object[] objects, Transaction txn, long lease, long[] leases, 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

Methods inherited from interface com.gigaspaces.internal.client.spaceproxy.ISpaceProxy

close, createNewOperationID, getContextTransaction, getNotificationsDirectProxy, getPrivilegedAdmin, initWriteModifiers, isClustered, loadRemoteClass, replaceContextTransaction, replaceContextTransaction

Methods inherited from interface com.j_spaces.core.IJSpace

getAdmin, getCacheTypeName, getDirectProxy, getFinderURL, getName, getReadModifiers, getReferentUuid, getUpdateModifiers, getURL, isEmbedded, isFifo, isOptimisticLockingEnabled, isSecured, isStartedWithinGSC, setFifo, setOptimisticLocking, setReadModifiers, setUpdateModifiers

Methods inherited from interface com.j_spaces.core.client.ActionMaker

setActionListener

Methods inherited from interface com.gigaspaces.security.service.SecuredService

isServiceSecured, login

Constructor Detail

AbstractSpaceProxy

protected AbstractSpaceProxy()

Method Detail

createActionManager

protected abstract AbstractSpaceProxyActionManager<?> createActionManager()

getContainerName

public String getContainerName()

Specified by:

getContainerName in interface IJSpace

write

public Lease write(Entry entry,
                   Transaction txn,
                   long lease)
            throws TransactionException,
                   RemoteException

Description copied from interface: JavaSpace

Write a new entry into the space. Equivalent to calling IPojoSpace.write(Object, Transaction, long, long, int) with UpdateModifiers.WRITE_ONLY.

Specified by:

write in interface JavaSpace

Parameters:

entry - the entry to write

txn - the transaction object, if any, under which to perform the write

lease - the requested lease time, in milliseconds

Returns:

a lease for the entry that was written to the space

Throws:

TransactionException - if a transaction error occurs

RemoteException - if a communication error occurs

read

public Entry read(Entry template,
                  Transaction txn,
                  long timeout)
           throws UnusableEntryException,
                  TransactionException,
                  InterruptedException,
                  RemoteException

Description copied from interface: JavaSpace

Read any matching entry from the space, blocking until one exists. Return null if the timeout expires.

Specified by:

read in interface JavaSpace

Parameters:

template - The template used for matching. Matching is done against tmpl with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

txn - The transaction (if any) under which to work.

timeout - How long the client is willing to wait for a transactionally proper matching entry. A timeout of NO_WAIT means to wait no time at all; this is equivalent to a wait of zero.

Returns:

a copy of the entry read from the space

Throws:

UnusableEntryException - if any serialized field of the entry being read cannot be deserialized for any reason

TransactionException - if a transaction error occurs

InterruptedException - if the thread in which the read occurs is interrupted

RemoteException - if a communication error occurs

readIfExists

public Entry readIfExists(Entry template,
                          Transaction txn,
                          long timeout)
                   throws UnusableEntryException,
                          TransactionException,
                          InterruptedException,
                          RemoteException

Description copied from interface: JavaSpace

Read any matching entry from the space, returning null if there is currently is none. Matching and timeouts are done as in read, except that blocking in this call is done only if necessary to wait for transactional state to settle.

Specified by:

readIfExists in interface JavaSpace

Parameters:

template - The template used for matching. Matching is done against tmpl with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

txn - The transaction (if any) under which to work.

timeout - How long the client is willing to wait for a transactionally proper matching entry. A timeout of NO_WAIT means to wait no time at all; this is equivalent to a wait of zero.

Returns:

a copy of the entry read from the space

Throws:

UnusableEntryException - if any serialized field of the entry being read cannot be deserialized for any reason

TransactionException - if a transaction error occurs

InterruptedException - if the thread in which the read occurs is interrupted

RemoteException - if a communication error occurs

See Also:

JavaSpace.read(net.jini.core.entry.Entry, net.jini.core.transaction.Transaction, long)

take

public Entry take(Entry template,
                  Transaction txn,
                  long timeout)
           throws UnusableEntryException,
                  TransactionException,
                  InterruptedException,
                  RemoteException

Description copied from interface: JavaSpace

Take a matching entry from the space, waiting until one exists. Matching is and timeout done as for read.

Specified by:

take in interface JavaSpace

Parameters:

template - The template used for matching. Matching is done against tmpl with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

txn - The transaction (if any) under which to work.

timeout - How long the client is willing to wait for a transactionally proper matching entry. A timeout of NO_WAIT means to wait no time at all; this is equivalent to a wait of zero.

Returns:

the entry taken from the space

Throws:

UnusableEntryException - if any serialized field of the entry being read cannot be deserialized for any reason

TransactionException - if a transaction error occurs

InterruptedException - if the thread in which the take occurs is interrupted

RemoteException - if a communication error occurs

See Also:

JavaSpace.read(net.jini.core.entry.Entry, net.jini.core.transaction.Transaction, long)

takeIfExists

public Entry takeIfExists(Entry template,
                          Transaction txn,
                          long timeout)
                   throws UnusableEntryException,
                          TransactionException,
                          InterruptedException,
                          RemoteException

Description copied from interface: JavaSpace

Take a matching entry from the space, returning null if there is currently is none. Matching is and timeout done as for read, except that blocking in this call is done only if necessary to wait for transactional state to settle.

Specified by:

takeIfExists in interface JavaSpace

Parameters:

template - The template used for matching. Matching is done against tmpl with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

txn - The transaction (if any) under which to work.

timeout - How long the client is willing to wait for a transactionally proper matching entry. A timeout of NO_WAIT means to wait no time at all; this is equivalent to a wait of zero.

Returns:

the entry taken from the space

Throws:

UnusableEntryException - if any serialized field of the entry being read cannot be deserialized for any reason

TransactionException - if a transaction error occurs

InterruptedException - if the thread in which the take occurs is interrupted

RemoteException - if a communication error occurs

See Also:

JavaSpace.read(net.jini.core.entry.Entry, net.jini.core.transaction.Transaction, long)

notify

public EventRegistration notify(Entry template,
                                Transaction txn,
                                RemoteEventListener listener,
                                long lease,
                                MarshalledObject handback)
                         throws TransactionException,
                                RemoteException

Description copied from interface: JavaSpace

When entries are written that match this template notify the given listener with a RemoteEvent that includes the handback object. Matching is done as for read.

Specified by:

notify in interface JavaSpace

Parameters:

template - The template used for matching. Matching is done against tmpl with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

txn - The transaction (if any) under which to work.

listener - The remote event listener to notify.

lease - the requested lease time, in milliseconds

handback - An object to send to the listener as part of the event notification.

Returns:

the event registration to the the registrant

Throws:

TransactionException - if a transaction error occurs

RemoteException - if a communication error occurs

See Also:

JavaSpace.read(net.jini.core.entry.Entry, net.jini.core.transaction.Transaction, long), EventRegistration

snapshot

public Entry snapshot(Entry e)
               throws RemoteException

Description copied from interface: JavaSpace

The process of serializing an entry for transmission to a JavaSpaces service will be identical if the same entry is used twice. This is most likely to be an issue with templates that are used repeatedly to search for entries with read or take. The client-side implementations of read and take cannot reasonably avoid this duplicated effort, since they have no efficient way of checking whether the same template is being used without intervening modification. The snapshot method gives the JavaSpaces service implementor a way to reduce the impact of repeated use of the same entry. Invoking snapshot with an Entry will return another Entry object that contains a snapshot of the original entry. Using the returned snapshot entry is equivalent to using the unmodified original entry in all operations on the same JavaSpaces service. Modifications to the original entry will not affect the snapshot. You can snapshot a null template; snapshot may or may not return null given a null template. The entry returned from snapshot will be guaranteed equivalent to the original unmodified object only when used with the space. Using the snapshot with any other JavaSpaces service will generate an IllegalArgumentException unless the other space can use it because of knowledge about the JavaSpaces service that generated the snapshot. The snapshot will be a different object from the original, may or may not have the same hash code, and equals may or may not return true when invoked with the original object, even if the original object is unmodified. A snapshot is guaranteed to work only within the virtual machine in which it was generated. If a snapshot is passed to another virtual machine (for example, in a parameter of an RMI call), using it--even with the same JavaSpaces service--may generate an IllegalArgumentException.

Specified by:

snapshot in interface JavaSpace

Parameters:

e - the entry to take a snapshot of.

Returns:

a snapshot of the entry.

Throws:

RemoteException - if a communication error occurs

getTypeDescriptor

public ITypeDesc getTypeDescriptor(String typeName)
                            throws RemoteException

Specified by:

getTypeDescriptor in interface ISpaceProxy

Throws:

RemoteException

registerTypeDescriptor

public void registerTypeDescriptor(ITypeDesc typeDesc)
                            throws RemoteException

Specified by:

registerTypeDescriptor in interface ISpaceProxy

Throws:

RemoteException

registerTypeDescriptor

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

Specified by:

registerTypeDescriptor in interface ISpaceProxy

Throws:

RemoteException

asyncAddIndexes

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

Specified by:

asyncAddIndexes in interface ISpaceProxy

Throws:

RemoteException

dropClass

public void dropClass(String className)
               throws RemoteException,
                      DropClassException

Description copied from interface: IJSpace

Drops all Class's entries and all its templates from this Space instance. Calling this method will remove all internal metadata related to this class stored in the Space. When using persistent spaced the relevant RDBMS table will be dropped. It is the caller responsibility to ensure that no entries from this class are written to the space while this method is called. This is not a clustered operation. If you want only to delete the entries, use clear operation.

Specified by:

dropClass in interface IJSpace

Parameters:

className - name of class to delete.

Throws:

RemoteException - if a communication error occurs

DropClassException - Failed to drop desired class.

See Also:

IPojoSpace.clear(Object, Transaction)

unregisterTypeDescriptor

public void unregisterTypeDescriptor(String typeName)
                              throws RemoteException

Specified by:

unregisterTypeDescriptor in interface ISpaceProxy

Throws:

RemoteException

clear

public void clear(Object template,
                  Transaction txn)
           throws RemoteException,
                  TransactionException,
                  UnusableEntryException

Specified by:

clear in interface IPojoSpace

Throws:

RemoteException

TransactionException

UnusableEntryException

clear

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

Specified by:

clear in interface IPojoSpace

Throws:

RemoteException

TransactionException

UnusableEntryException

count

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

Specified by:

count in interface IPojoSpace

Throws:

RemoteException

TransactionException

UnusableEntryException

count

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

Specified by:

count in interface IPojoSpace

Throws:

RemoteException

TransactionException

UnusableEntryException

execute

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

Description copied from interface: ISpaceProxy

Executes a task on a single space.

Specified by:

execute in interface ISpaceProxy

Parameters:

task - task (non-null) to execute on single space, according to the routing field.

tx - transaction (if any) under which to work.

listener - event listener to execute result.

Returns:

future to retrieve the result in an asynchronous way

Throws:

TransactionException - if a transaction error occurs

RemoteException - if a communication error occurs

ping

public void ping()
          throws RemoteException

Description copied from interface: IJSpace

Checks whether the space is alive and accessible.

Specified by:

ping in interface IJSpace

Throws:

RemoteException - when space was unreachable

getSpaceHealthStatus

public SpaceHealthStatus getSpaceHealthStatus()
                                       throws RemoteException

Description copied from interface: ISpaceProxy

Gets an object representing the space health status

Specified by:

getSpaceHealthStatus in interface ISpaceProxy

Returns:

object representing the space health status

Throws:

RemoteException

read

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

Specified by:

read in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

read

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

Specified by:

read in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

read

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

Specified by:

read in interface ISpaceProxy

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

asyncRead

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

Description copied from interface: ISpaceProxy

Internal methods only. Read any matching entry from the space, unblocking. Returns an AsyncFuture which returns null if the timeout expires.

Specified by:

asyncRead in interface ISpaceProxy

Parameters:

template - The template used for matching. Matching is done against template with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

txn - The template used for matching. Matching is done against template with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

timeout - How long the client is willing to wait for a transactionally proper matching entry. A timeout of NO_WAIT means to wait no time at all; this is equivalent to a wait of zero.

modifiers - one or a union of ReadModifiers.

listener - event listener to execute result.

Returns:

object from the space

Throws:

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

Specified by:

readById in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

readById

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

Specified by:

readById in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

takeById

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

Specified by:

takeById in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

readByUid

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

Specified by:

readByUid in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

readIfExists

public Object readIfExists(Object template,
                           Transaction txn,
                           long timeout)
                    throws UnusableEntryException,
                           TransactionException,
                           InterruptedException,
                           RemoteException

Specified by:

readIfExists in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

readIfExists

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

Specified by:

readIfExists in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

readMultiple

public Object[] readMultiple(Object template,
                             Transaction txn,
                             int maxEntries)
                      throws TransactionException,
                             UnusableEntryException,
                             RemoteException

Specified by:

readMultiple in interface IPojoSpace

Throws:

TransactionException

UnusableEntryException

RemoteException

readMultiple

public Object[] readMultiple(Object template,
                             Transaction txn,
                             int maxEntries,
                             int modifiers)
                      throws TransactionException,
                             UnusableEntryException,
                             RemoteException

Specified by:

readMultiple in interface IPojoSpace

Throws:

TransactionException

UnusableEntryException

RemoteException

readMultiple

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

Specified by:

readMultiple in interface ISpaceProxy

Throws:

TransactionException

UnusableEntryException

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

Specified by:

readMultiple in interface ISpaceProxy

Throws:

TransactionException

UnusableEntryException

RemoteException

snapshot

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

Specified by:

snapshot in interface IPojoSpace

Throws:

RemoteException

take

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

Specified by:

take in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

take

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

Specified by:

take in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

take

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

Specified by:

take in interface ISpaceProxy

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

asyncTake

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

Description copied from interface: ISpaceProxy

Internal methods only. Take any matching entry from the space, unblocking. Returns an AsyncFuture which returns null if the timeout expires.

Specified by:

asyncTake in interface ISpaceProxy

Parameters:

template - The template used for matching. Matching is done against template with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

txn - The template used for matching. Matching is done against template with null fields being wildcards ("match anything") other fields being values ("match exactly on the serialized form").

timeout - How long the client is willing to wait for a transactionally proper matching entry. A timeout of NO_WAIT means to wait no time at all; this is equivalent to a wait of zero.

modifiers - one or a union of ReadModifiers.

listener - event listener to execute result.

Returns:

object from the space

Throws:

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

Specified by:

takeById in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

takeByUid

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

Specified by:

takeByUid in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

takeIfExists

public Object takeIfExists(Object template,
                           Transaction txn,
                           long timeout)
                    throws UnusableEntryException,
                           TransactionException,
                           InterruptedException,
                           RemoteException

Specified by:

takeIfExists in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

takeIfExists

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

Throws:

UnusableEntryException

TransactionException

InterruptedException

RemoteException

takeMultiple

public Object[] takeMultiple(Object template,
                             Transaction txn,
                             int maxEntries)
                      throws TransactionException,
                             UnusableEntryException,
                             RemoteException

Specified by:

takeMultiple in interface IPojoSpace

Throws:

TransactionException

UnusableEntryException

RemoteException

takeMultiple

public Object[] takeMultiple(Object template,
                             Transaction txn,
                             int maxEntries,
                             int modifiers)
                      throws TransactionException,
                             UnusableEntryException,
                             RemoteException

Specified by:

takeMultiple in interface IPojoSpace

Throws:

TransactionException

UnusableEntryException

RemoteException

takeMultiple

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

Specified by:

takeMultiple in interface ISpaceProxy

Throws:

TransactionException

UnusableEntryException

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

Specified by:

takeMultiple in interface ISpaceProxy

Throws:

TransactionException

UnusableEntryException

RemoteException

update

public Object update(Object updatedEntry,
                     Transaction transaction,
                     long lease,
                     long timeout)
              throws TransactionException,
                     UnusableEntryException,
                     RemoteException,
                     InterruptedException

Specified by:

update in interface IPojoSpace

Throws:

TransactionException

UnusableEntryException

RemoteException

InterruptedException

update

public Object update(Object entry,
                     Transaction txn,
                     long lease,
                     long timeout,
                     int modifiers)
              throws TransactionException,
                     UnusableEntryException,
                     RemoteException,
                     InterruptedException

Specified by:

update in interface IPojoSpace

Throws:

TransactionException

UnusableEntryException

RemoteException

InterruptedException

updateMultiple

public Object[] updateMultiple(Object[] entries,
                               Transaction txn,
                               long[] leases)
                        throws UnusableEntryException,
                               TransactionException,
                               RemoteException

Specified by:

updateMultiple in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

RemoteException

updateMultiple

public Object[] updateMultiple(Object[] entries,
                               Transaction txn,
                               long[] leases,
                               int modifiers)
                        throws UnusableEntryException,
                               TransactionException,
                               RemoteException

Specified by:

updateMultiple in interface IPojoSpace

Throws:

UnusableEntryException

TransactionException

RemoteException

write

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

Specified by:

write in interface IPojoSpace

Throws:

TransactionException

RemoteException

write

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

Specified by:

write in interface IPojoSpace

Throws:

TransactionException

RemoteException

writeMultiple

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

Specified by:

writeMultiple in interface IPojoSpace

Throws:

TransactionException

RemoteException

writeMultiple

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

Specified by:

writeMultiple in interface IPojoSpace

Throws:

TransactionException

RemoteException

writeMultiple

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

Specified by:

writeMultiple in interface IPojoSpace

Throws:

TransactionException

RemoteException

writeMultiple

public LeaseContext<?>[] writeMultiple(Object[] objects,
                                       Transaction txn,
                                       long lease,
                                       long[] leases,
                                       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

Specified by:

writeMultiple in interface ISpaceProxy

Throws:

TransactionException

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

Specified by:

readByIds in interface ISpaceProxy

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

Specified by:

readByIds in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

readByIds

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

Specified by:

readByIds in interface ISpaceProxy

Throws:

RemoteException

TransactionException

InterruptedException

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

Specified by:

takeByIds in interface ISpaceProxy

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

Specified by:

takeByIds in interface ISpaceProxy

Throws:

RemoteException

UnusableEntryException

TransactionException

InterruptedException

takeByIds

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

Specified by:

takeByIds in interface ISpaceProxy

Throws:

RemoteException

TransactionException

InterruptedException

UnusableEntryException

readEntriesUids

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

Description copied from interface: ISpaceProxy

Read entries UIDs from space.

Specified by:

readEntriesUids in interface ISpaceProxy

Throws:

RemoteException

TransactionException

UnusableEntryException

change

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

Description copied from interface: ISpaceProxy

Change entry in space

Specified by:

change in interface ISpaceProxy

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

Specified by:

asyncChange in interface ISpaceProxy

Throws:

RemoteException

aggregate

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

Specified by:

aggregate in interface ISpaceProxy

Throws:

RemoteException

TransactionException

InterruptedException

setAppDomainId

public void setAppDomainId(int appDomainId)

Description copied from interface: IDotnetProxyAssociated

associate this object to the specified AppDomain id

Specified by:

setAppDomainId in interface IDotnetProxyAssociated

hasAssociatedAppDomain

public boolean hasAssociatedAppDomain()

Specified by:

hasAssociatedAppDomain in interface IDotnetProxyAssociated

Returns:

true if this object is associated to an AppDomain.

getAppDomainId

public int getAppDomainId()

Specified by:

getAppDomainId in interface IDotnetProxyAssociated

Returns:

the id of the associated AppDomain, throws an exception if this object is not associated to any AppDomain. IDotnetProxyAssociated.hasAssociatedAppDomain()

setDotnetProxyHandleId

public void setDotnetProxyHandleId(long handleId)

Description copied from interface: IDotnetProxyAssociated

Sets a dotnet proxy handle id

Specified by:

setDotnetProxyHandleId in interface IDotnetProxyAssociated

Parameters:

handleId - handle id of the proxy

isTargetOfADotnetProxy

public boolean isTargetOfADotnetProxy()

Specified by:

isTargetOfADotnetProxy in interface IDotnetProxyAssociated

Returns:

true if this object is a target .NET proxy

getDotnetProxyHandleId

public long getDotnetProxyHandleId()

Specified by:

getDotnetProxyHandleId in interface IDotnetProxyAssociated

Returns:

the handle id of this object that the proxy is using.

applyNotifyInfoDefaults

public void applyNotifyInfoDefaults(NotifyInfo notifyInfo)

Specified by:

applyNotifyInfoDefaults in interface ISpaceProxy

checkIfConnected

public boolean checkIfConnected()

Specified by:

checkIfConnected in interface ISpaceProxy

isCacheContainer

public boolean isCacheContainer()

getLocalSpace

public IDirectSpaceProxy getLocalSpace()

getRemoteSpace

public IDirectSpaceProxy getRemoteSpace()

isLocalCacheCacheContainer

public boolean isLocalCacheCacheContainer()

isLocalViewContainer

public boolean isLocalViewContainer()