public interface ISpaceProxy extends IJSpace, ActionMaker, SecuredService, IDotnetProxyAssociated, JavaSpace
IJSpace interface. Operations that need
to be provided by a space proxy but are not exposed as an API through the IJSpace interface should go here.| 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 transaction,
long timeout,
int modifiers,
AsyncFutureListener listener)
Internal methods only.
|
AsyncFuture |
asyncTake(Object template,
Transaction transaction,
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 |
close()
Close the proxy and execute necessary cleanup logic.
|
OperationID |
createNewOperationID()
Generate a unique operation ID
|
AsyncFuture |
execute(SpaceTask task,
Object routing,
Transaction tx,
AsyncFutureListener listener)
Executes a task on a single space.
|
Transaction.Created |
getContextTransaction()
Returns the transaction associated with the current context, if any.
|
IDirectSpaceProxy |
getNotificationsDirectProxy()
returns itself in case of a direct proxy or the real proxy in case of a local cache or a
view.
|
Object |
getPrivilegedAdmin()
Deprecated.
since 7.0.1. Is not part of current security model.
|
SpaceHealthStatus |
getSpaceHealthStatus()
Gets an object representing the space health status
|
ITypeDesc |
getTypeDescriptor(String typeName) |
int |
initWriteModifiers(int modifiers) |
boolean |
isClustered()
returns true if the proxy is Clustered
|
Class<?> |
loadRemoteClass(String className)
Loads a remote class from the space, the class will be loaded locally into a corresponding
LRMIClassLoader
|
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.
|
Object[] |
readMultiple(Object template,
Transaction transaction,
int limit,
int modifiers,
boolean returnOnlyUids) |
Object[] |
readMultiple(Object template,
Transaction transaction,
long timeout,
int limit,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
ITypeDesc |
registerTypeDescriptor(Class<?> type) |
void |
registerTypeDescriptor(ITypeDesc typeDesc) |
Transaction.Created |
replaceContextTransaction(Transaction.Created transaction) |
Transaction.Created |
replaceContextTransaction(Transaction.Created transaction,
ActionListener actionListener,
boolean delegatedXa) |
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) |
Object[] |
takeMultiple(Object template,
Transaction transaction,
int limit,
int modifiers,
boolean returnOnlyUids) |
Object[] |
takeMultiple(Object template,
Transaction transaction,
long timeout,
int limit,
int minEntriesToWaitFor,
int modifiers,
boolean returnOnlyUids,
boolean ifExist) |
void |
unregisterTypeDescriptor(String typeName) |
LeaseContext[] |
writeMultiple(Object[] objects,
Transaction txn,
long lease,
long[] leases,
long timeout,
int modifiers) |
dropClass, getAdmin, getCacheTypeName, getContainerName, getDirectProxy, getFinderURL, getName, getReadModifiers, getReferentUuid, getUpdateModifiers, getURL, isEmbedded, isFifo, isOptimisticLockingEnabled, isSecured, isStartedWithinGSC, ping, setFifo, setOptimisticLocking, setReadModifiers, setUpdateModifiersclear, clear, count, count, read, read, readIfExists, readIfExists, readMultiple, readMultiple, snapshot, take, take, takeIfExists, takeMultiple, takeMultiple, update, update, updateMultiple, updateMultiple, write, write, writeMultiple, writeMultiple, writeMultiplesetActionListenerisServiceSecured, logingetAppDomainId, getDotnetProxyHandleId, hasAssociatedAppDomain, isTargetOfADotnetProxy, setAppDomainId, setDotnetProxyHandleIdnotify, read, readIfExists, snapshot, take, takeIfExists, writeTransaction.Created getContextTransaction()
Transaction.Created replaceContextTransaction(Transaction.Created transaction)
Transaction.Created replaceContextTransaction(Transaction.Created transaction, ActionListener actionListener, boolean delegatedXa)
boolean isClustered()
IDirectSpaceProxy getNotificationsDirectProxy()
@Deprecated Object getPrivilegedAdmin() throws RemoteException
RemoteExceptionIJSpace.getAdmin()AsyncFuture execute(SpaceTask task, Object routing, Transaction tx, AsyncFutureListener listener) throws TransactionException, RemoteException
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.TransactionException - if a transaction error occursRemoteException - if a communication error occursvoid close()
AsyncFuture asyncTake(Object template, Transaction transaction, long timeout, int modifiers, AsyncFutureListener listener) throws RemoteException
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").transaction - 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.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 IllegalArgumentException - if a
negative timeout value is usedRemoteExceptionAsyncFuture asyncRead(Object template, Transaction transaction, long timeout, int modifiers, AsyncFutureListener listener) throws RemoteException
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").transaction - 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.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 IllegalArgumentException - if a
negative timeout value is usedRemoteExceptionObject read(Object template, Transaction txn, long timeout, int modifiers, boolean ifExists) throws UnusableEntryException, TransactionException, InterruptedException, RemoteException
Object take(Object template, Transaction txn, long timeout, int modifiers, boolean ifExists) throws UnusableEntryException, TransactionException, InterruptedException, RemoteException
Object[] readMultiple(Object template, Transaction transaction, int limit, int modifiers, boolean returnOnlyUids) throws TransactionException, UnusableEntryException, RemoteException
Object[] readMultiple(Object template, Transaction transaction, long timeout, int limit, int minEntriesToWaitFor, int modifiers, boolean returnOnlyUids, boolean ifExist) throws TransactionException, UnusableEntryException, RemoteException
Object[] takeMultiple(Object template, Transaction transaction, int limit, int modifiers, boolean returnOnlyUids) throws TransactionException, UnusableEntryException, RemoteException
Object[] takeMultiple(Object template, Transaction transaction, long timeout, int limit, int minEntriesToWaitFor, int modifiers, boolean returnOnlyUids, boolean ifExist) throws TransactionException, UnusableEntryException, RemoteException
Object readById(ReadTakeProxyActionInfo actionInfo) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
Object takeById(ReadTakeProxyActionInfo actionInfo) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
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
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
Object readByUid(String uid, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPacket) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
Object takeByUid(String uid, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPacket) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
Object[] readByIds(String className, Object[] ids, Object routing, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
Object[] readByIds(String className, Object[] ids, Object[] routings, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
Object[] readByIds(ReadTakeByIdsProxyActionInfo actionInfo, boolean returnPackets) throws RemoteException, TransactionException, InterruptedException, UnusableEntryException
Object[] takeByIds(String className, Object[] ids, Object routing, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
Object[] takeByIds(String className, Object[] ids, Object[] routings, Transaction txn, int modifiers, QueryResultTypeInternal resultType, boolean returnPackets, String[] projections) throws RemoteException, UnusableEntryException, TransactionException, InterruptedException
Object[] takeByIds(ReadTakeByIdsProxyActionInfo actionInfo, boolean returnPackets) throws RemoteException, TransactionException, InterruptedException, UnusableEntryException
LeaseContext[] writeMultiple(Object[] objects, Transaction txn, long lease, long[] leases, long timeout, int modifiers) throws TransactionException, RemoteException
TransactionExceptionRemoteExceptionSpaceHealthStatus getSpaceHealthStatus() throws RemoteException
RemoteExceptionITypeDesc getTypeDescriptor(String typeName) throws RemoteException
RemoteExceptionvoid registerTypeDescriptor(ITypeDesc typeDesc) throws RemoteException
RemoteExceptionITypeDesc registerTypeDescriptor(Class<?> type) throws RemoteException
RemoteExceptionvoid unregisterTypeDescriptor(String typeName) throws RemoteException
RemoteExceptionAsyncFuture<AddTypeIndexesResult> asyncAddIndexes(String typeName, SpaceIndex[] indexes, AsyncFutureListener<AddTypeIndexesResult> listener) throws RemoteException
RemoteExceptionClass<?> loadRemoteClass(String className) throws ClassNotFoundException
ClassNotFoundExceptionvoid applyNotifyInfoDefaults(NotifyInfo notifyInfo)
boolean checkIfConnected()
OperationID createNewOperationID()
int initWriteModifiers(int modifiers)
ReadTakeEntriesUidsResult readEntriesUids(ITemplatePacket template, Transaction transaction, int entriesLimit, int modifiers) throws RemoteException, TransactionException, UnusableEntryException
RemoteExceptionTransactionExceptionUnusableEntryException<T> ChangeResult<T> change(Object template, ChangeSet changeSet, Transaction txn, long timeout, ChangeModifiers modifiers) throws RemoteException, TransactionException
RemoteExceptionTransactionException<T> Future<ChangeResult<T>> asyncChange(Object template, ChangeSet changeSet, Transaction txn, long timeout, ChangeModifiers modifiers, AsyncFutureListener<ChangeResult<T>> listener) throws RemoteException
RemoteExceptionAggregationResult aggregate(Object template, AggregationSet aggregationSet, Transaction txn, int readModifiers) throws RemoteException, TransactionException, InterruptedException
Copyright © GigaSpaces.