Package | Description |
---|---|
net.jini.core.transaction |
These are the transaction abstraction's interfaces and classes.
|
net.jini.core.transaction.server |
These are the default transaction semantics for participant/manager interaction.
|
net.jini.space |
JavaSpaces servers provide a place on the network, a space,
for clients to store and exchange objects.
|
org.apache.river.mahalo |
Provides implementations of the
TransactionManager service.
|
org.apache.river.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
Modifier and Type | Class and Description |
---|---|
class |
CannotAbortException
Exception thrown when a transaction cannot abort because it has already
already decided to commit.
|
class |
CannotCommitException
Exception thrown when a transaction cannot commit because it has already
aborted or must now be aborted.
|
class |
CannotJoinException
Exception thrown when a transaction cannot be joined because it is no
longer active.
|
class |
CannotNestException
Exception thrown when an object does not support nested transactions.
|
class |
TimeoutExpiredException
Exception thrown when a transaction timeout has expired.
|
class |
UnknownTransactionException
Exception thrown when a transaction is not recognized as a valid
or known transaction.
|
Modifier and Type | Class and Description |
---|---|
class |
CrashCountException
Exception thrown when a transaction cannot be joined because the
participant's current crash count is different from the crash
count the manager received in a previous join by that participant.
|
Modifier and Type | Method and Description |
---|---|
MatchSet |
JavaSpace05.contents(Collection tmpls,
Transaction txn,
long leaseDuration,
long maxEntries)
Creates a match set that can be used to
exhaustively read through all of the matching entries in
the space that are visible to the passed
Transaction and remain visible for the lifetime of the
match set. |
EventRegistration |
JavaSpace.notify(Entry tmpl,
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. |
Entry |
JavaSpace.read(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, blocking until one exists.
|
Entry |
JavaSpace.readIfExists(Entry tmpl,
Transaction txn,
long timeout)
Read any matching entry from the space, returning
null if there is currently is none. |
EventRegistration |
JavaSpace05.registerForAvailabilityEvent(Collection tmpls,
Transaction txn,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseDuration,
MarshalledObject handback)
Register for events triggered when a matching
Entry
transitions from unavailable to available. |
Collection |
JavaSpace05.take(Collection tmpls,
Transaction txn,
long timeout,
long maxEntries)
This method provides an overload of the
JavaSpace.take method that attempts to
remove, optionally under a Transaction , and return
one or more entries from the space. |
Entry |
JavaSpace.take(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, waiting until one exists.
|
Entry |
JavaSpace.takeIfExists(Entry tmpl,
Transaction txn,
long timeout)
Take a matching entry from the space, returning
null if there is currently is none. |
Lease |
JavaSpace.write(Entry entry,
Transaction txn,
long lease)
Write a new entry into the space.
|
List |
JavaSpace05.write(List entries,
Transaction txn,
List leaseDurations)
This method provides an overload of the
JavaSpace.write method that allows new
copies of multiple Entry instances to be stored in
the space using a single call. |
Modifier and Type | Method and Description |
---|---|
int |
TxnManagerTransaction.atomicCheckExpirationIfActive() |
int |
TxnManagerTransaction.atomicCheckStateActive()
Atomic check that state is ACTIVE.
|
Modifier and Type | Method and Description |
---|---|
private EntryRep[] |
OutriggerServerImpl.completeTake(EntryHandle[] handles,
int found,
Txn txn) |
private EntryRep |
OutriggerServerImpl.completeTake(EntryHandle handle,
Txn txn) |
MatchSet |
SpaceProxy2.contents(Collection tmpls,
Transaction txn,
long leaseDuration,
long maxEntries) |
MatchSetData |
OutriggerServerWrapper.contents(EntryRep[] tmpls,
Transaction tr,
long leaseTime,
long limit) |
MatchSetData |
OutriggerServerImpl.contents(EntryRep[] tmpls,
Transaction tr,
long leaseTime,
long limit) |
MatchSetData |
OutriggerServer.contents(EntryRep[] tmpls,
Transaction tr,
long leaseTime,
long limit)
Start a new contents query.
|
Uuid |
OutriggerServerWrapper.contents(EntryRep tmpl,
Transaction txn) |
Uuid |
OutriggerServerImpl.contents(EntryRep tmpl,
Transaction tr) |
Uuid |
OutriggerAdmin.contents(EntryRep tmpl,
Transaction txn)
Return the remote iterator object needed by
JavaSpaceAdmin.contents . |
AdminIterator |
JavaSpaceAdmin.contents(Entry tmpl,
Transaction txn)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableJavaSpaceAdmin.contents(Entry tmpl,
Transaction txn)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
AdminProxy.contents(Entry tmpl,
Transaction tr) |
AdminIterator |
JavaSpaceAdmin.contents(Entry tmpl,
Transaction txn,
int fetchSize)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableJavaSpaceAdmin.contents(Entry tmpl,
Transaction txn,
int fetchSize)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableAdminProxy.contents(Entry tmpl,
Transaction tr,
int fetchSize)
Override super class to create secure
IteratorProxy s |
AdminIterator |
AdminProxy.contents(Entry tmpl,
Transaction tr,
int fetchSize) |
AdminIterator |
ConstrainableJavaSpaceAdmin.contents(Entry tmpl,
Transaction txn,
int fetchSize,
MethodConstraints constrains)
Deprecated.
Return an
AdminIterator that will iterate over all
the entries in the space that match the given template and are
visible under the given transaction. |
AdminIterator |
ConstrainableAdminProxy.contents(Entry tmpl,
Transaction txn,
int fetchSize,
MethodConstraints constraints) |
private Txn |
OutriggerServerImpl.enterTxn(Transaction baseTr)
This method takes a transactional semantic object
baseTr (the transaction object passed to us by the
client) and retrieves the associated Txn object
(the internal representation for that transaction) from the
space's records. |
private EntryHandle |
OutriggerServerImpl.find(EntryRep tmplRep,
Txn txn,
boolean takeIt,
Set conflictSet,
Set lockedEntrySet,
Set<EntryHandle> provisionallyRemovedEntrySet)
Find an entry that is at least
whichClass that
matches the template tmplRep (at least the
template's type, and matches in values provided). |
private Object |
OutriggerServerImpl.getMatch(EntryRep tmpl,
Transaction tr,
long timeout,
boolean takeIt,
boolean ifExists,
OutriggerServer.QueryCookie queryCookieFromClient)
Do the heavy lifting for queries.
|
private EntryRep[] |
OutriggerServerImpl.ContentsQuery.nextBatch(Uuid lastReceived,
long now) |
EventRegistration |
OutriggerServerWrapper.notify(EntryRep tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback) |
EventRegistration |
OutriggerServerImpl.notify(EntryRep tmpl,
Transaction tr,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback) |
EventRegistration |
OutriggerServer.notify(EntryRep tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback)
When entries are written that match this template notify the
given
listener . |
EventRegistration |
SpaceProxy2.notify(Entry tmpl,
Transaction txn,
RemoteEventListener listener,
long lease,
MarshalledObject handback) |
Object |
OutriggerServerWrapper.read(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.read(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.read(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find an entry in the space that matches the passed template and
is visible to the passed transaction.
|
Entry |
SpaceProxy2.read(Entry tmpl,
Transaction txn,
long timeout) |
Object |
OutriggerServerWrapper.readIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.readIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.readIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find an entry in the space that matches the passed template and
is visible to the passed transaction.
|
Entry |
SpaceProxy2.readIfExists(Entry tmpl,
Transaction txn,
long timeout) |
EventRegistration |
SpaceProxy2.registerForAvailabilityEvent(Collection tmpls,
Transaction txn,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseDuration,
MarshalledObject handback) |
EventRegistration |
OutriggerServerWrapper.registerForAvailabilityEvent(EntryRep[] tmpls,
Transaction txn,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback) |
EventRegistration |
OutriggerServerImpl.registerForAvailabilityEvent(EntryRep[] tmpls,
Transaction tr,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback) |
EventRegistration |
OutriggerServer.registerForAvailabilityEvent(EntryRep[] tmpls,
Transaction txn,
boolean visibilityOnly,
RemoteEventListener listener,
long leaseTime,
MarshalledObject handback)
When entries that match one or more of the passed templates
transition from invisible to visible notify the give
listener . |
Collection |
SpaceProxy2.take(Collection tmpls,
Transaction txn,
long timeout,
long maxEntries) |
Object |
OutriggerServerWrapper.take(EntryRep[] tmpls,
Transaction tr,
long timeout,
int limit,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.take(EntryRep[] tmpls,
Transaction tr,
long timeout,
int limit,
OutriggerServer.QueryCookie queryCookieFromClient) |
Object |
OutriggerServer.take(EntryRep[] tmpls,
Transaction tr,
long timeout,
int limit,
OutriggerServer.QueryCookie cookie)
Find and remove up to
limit entries in the space
that match one or more of the passed templates and are visible
to the passed transaction. |
Object |
OutriggerServerWrapper.take(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.take(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.take(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find and remove an entry in the space that matches the passed
template and is visible to the passed transaction.
|
Entry |
SpaceProxy2.take(Entry tmpl,
Transaction txn,
long timeout) |
Object |
OutriggerServerWrapper.takeIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServerImpl.takeIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie) |
Object |
OutriggerServer.takeIfExists(EntryRep tmpl,
Transaction txn,
long timeout,
OutriggerServer.QueryCookie cookie)
Find and remove an entry in the space that matches the passed
template and is visible to the passed transaction.
|
Entry |
SpaceProxy2.takeIfExists(Entry tmpl,
Transaction txn,
long timeout) |
long[] |
OutriggerServerWrapper.write(EntryRep[] entries,
Transaction txn,
long[] leaseTimes) |
long[] |
OutriggerServerImpl.write(EntryRep[] entries,
Transaction tr,
long[] leaseTimes) |
long[] |
OutriggerServer.write(EntryRep[] entries,
Transaction txn,
long[] leaseTimes)
Write a set of entires into the space.
|
long[] |
OutriggerServerWrapper.write(EntryRep entry,
Transaction txn,
long lease) |
long[] |
OutriggerServerImpl.write(EntryRep rep,
Transaction tr,
long lease) |
long[] |
OutriggerServer.write(EntryRep entry,
Transaction txn,
long lease)
Write a new entry into the space.
|
Lease |
SpaceProxy2.write(Entry entry,
Transaction txn,
long lease) |
List |
SpaceProxy2.write(List entries,
Transaction txn,
List leaseDurations) |
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.