Package | Description |
---|---|
net.jini.discovery |
These are utility classes and interfaces that conform to the discovery and join
protocol defined in the Jini Discovery and Join Specification.
|
net.jini.lookup |
Standard utility classes for managing the join state of a service
and the service discovery duties of a client or service.
|
net.jini.security |
Provides mechanisms and abstractions for managing security, especially in the
presence of dynamically downloaded code.
|
org.apache.river.example.browser |
A visualization tool for exploring Jini Network Technology
communities (djinns) with support for ServiceUI.
|
org.apache.river.fiddler |
Provides the server side of an implementation of the lookup discovery service
(see
). |
org.apache.river.mahalo |
Provides implementations of the
TransactionManager service.
|
org.apache.river.mercury |
Provides implementations of the
EventMailbox service.
|
org.apache.river.norm |
Provides implementations of
LeaseRenewalService . |
org.apache.river.norm.event | |
org.apache.river.norm.lookup | |
org.apache.river.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
org.apache.river.phoenix |
A configurable Java(TM) Remote Method Invocation (Java RMI) activation
system daemon implementation.
|
org.apache.river.reggie |
Provides implementations of
ServiceRegistrar . |
org.apache.river.start |
Provides the utilities and APIs used to launch the contributed services
provided in the Apache River release.
|
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
AbstractLookupLocatorDiscovery.registrarPreparer |
(package private) ProxyPreparer |
AbstractLookupLocatorDiscovery.Initializer.registrarPreparer |
private ProxyPreparer |
AbstractLookupDiscovery.registrarPreparer |
(package private) ProxyPreparer |
AbstractLookupDiscovery.Initializer.registrarPreparer |
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
ServiceDiscoveryManager.eventLeasePreparer |
(package private) ProxyPreparer |
ServiceDiscoveryManager.Initializer.eventLeasePreparer |
private ProxyPreparer |
ServiceDiscoveryManager.registrarPreparer |
(package private) ProxyPreparer |
ServiceDiscoveryManager.Initializer.registrarPreparer |
private ProxyPreparer |
JoinManager.registrarPreparer |
(package private) ProxyPreparer |
JoinManager.Conf.registrarPreparer |
private ProxyPreparer |
JoinManager.registrationPreparer |
(package private) ProxyPreparer |
JoinManager.Conf.registrationPreparer |
private ProxyPreparer |
JoinManager.serviceLeasePreparer |
(package private) ProxyPreparer |
JoinManager.Conf.serviceLeasePreparer |
Constructor and Description |
---|
Conf(ProxyPreparer registrarPreparer,
ProxyPreparer registrationPreparer,
ProxyPreparer serviceLeasePreparer,
java.util.concurrent.ExecutorService taskManager,
WakeupManager wakeupManager,
Integer maxNretrys,
LeaseRenewalManager leaseRenewalManager,
Long renewalDuration,
DiscoveryManagement discoveryMgr,
boolean bcreateDisco) |
Modifier and Type | Class and Description |
---|---|
class |
BasicProxyPreparer
A
ProxyPreparer for verifying that proxies are trusted,
granting them dynamic permissions, and setting their constraints, as well as
for creating other proxy preparer subclasses that include those
operations. |
class |
VerifyingProxyPreparer
A
ProxyPreparer for verifying that proxies are trusted,
dynamically granting permissions to trusted proxies, and optionally
setting the client constraints on trusted proxies. |
Modifier and Type | Field and Description |
---|---|
(package private) ProxyPreparer |
Browser.adminPreparer |
(package private) ProxyPreparer |
Browser.leasePreparer |
(package private) ProxyPreparer |
Browser.servicePreparer |
Modifier and Type | Field and Description |
---|---|
(package private) ProxyPreparer |
FiddlerInit.listenerPreparer |
private ProxyPreparer |
FiddlerImpl.listenerPreparer |
(package private) ProxyPreparer |
FiddlerInit.locatorToDiscoverPreparer |
private ProxyPreparer |
FiddlerImpl.locatorToDiscoverPreparer |
(package private) ProxyPreparer |
FiddlerInit.locatorToJoinPreparer |
private ProxyPreparer |
FiddlerImpl.locatorToJoinPreparer |
(package private) ProxyPreparer |
FiddlerInit.recoveredListenerPreparer |
private ProxyPreparer |
FiddlerImpl.recoveredListenerPreparer |
(package private) ProxyPreparer |
FiddlerInit.recoveredLocatorToDiscoverPreparer |
private ProxyPreparer |
FiddlerImpl.recoveredLocatorToDiscoverPreparer |
(package private) ProxyPreparer |
FiddlerInit.recoveredLocatorToJoinPreparer |
private ProxyPreparer |
FiddlerImpl.recoveredLocatorToJoinPreparer |
Modifier and Type | Method and Description |
---|---|
void |
FiddlerImpl.RegistrationInfo.prepare(ProxyPreparer recoveredListenerPreparer,
ProxyPreparer recoveredLocatorToDiscoverPreparer)
Must be called immediately after de-serialization to prepare
proxies.
|
private static void |
FiddlerImpl.prepareNewLocators(ProxyPreparer preparer,
LookupLocator[] locators)
Using the given
ProxyPreparer , attempts to prepare each
element of the given LookupLocator array; replacing the
original element of the array with the result of the call to the
method ProxyPreparer.prepareProxy . |
private static LookupLocator[] |
FiddlerImpl.prepareOldLocators(ProxyPreparer preparer,
LookupLocator[] locators)
Using the given
ProxyPreparer , attempts to prepare each
element of the given LookupLocator array; and returns
a new array containing the prepared locators. |
private static Set |
FiddlerImpl.prepareOldLocators(ProxyPreparer preparer,
Set locators)
Using the given
ProxyPreparer , attempts to prepare each
element of the given Set of LookupLocator
instances; and returns a new Set containing the prepared
locators. |
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
JoinStateManager.lookupLocatorPreparer
ProxyPreparer for LookupLocators |
(package private) ProxyPreparer |
TxnManagerImplInitializer.participantPreparer |
private ProxyPreparer |
TxnManagerImpl.participantPreparer
Proxy preparer for listeners
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
TxnManagerTransaction.restoreTransientState(ProxyPreparer preparer) |
(package private) void |
ParticipantHandle.restoreTransientState(ProxyPreparer recoveredListenerPreparer) |
Modifier and Type | Field and Description |
---|---|
(package private) ProxyPreparer |
MailboxImplInit.listenerPreparer |
private ProxyPreparer |
MailboxImpl.listenerPreparer
Proxy preparer for listeners
|
(package private) ProxyPreparer |
MailboxImplInit.locatorToJoinPreparer |
private static ProxyPreparer |
MailboxImpl.locatorToJoinPreparer |
(package private) ProxyPreparer |
MailboxImplInit.recoveredListenerPreparer |
private ProxyPreparer |
MailboxImpl.recoveredListenerPreparer
Proxy preparer recovered
|
(package private) ProxyPreparer |
MailboxImplInit.recoveredLocatorToJoinPreparer |
private static ProxyPreparer |
MailboxImpl.recoveredLocatorToJoinPreparer |
Modifier and Type | Method and Description |
---|---|
(package private) static LookupLocator[] |
MailboxImpl.prepareExistingLocators(ProxyPreparer preparer,
LookupLocator[] lookupLocators) |
private static void |
MailboxImpl.prepareNewLocators(ProxyPreparer preparer,
LookupLocator[] locators)
Using the given
ProxyPreparer , attempts to prepare each
element of the given LookupLocator array; replacing the
original element of the array with the result of the call to the
method ProxyPreparer.prepareProxy . |
void |
ServiceRegistration.restoreTransientState(ProxyPreparer targetPreparer) |
Modifier and Type | Field and Description |
---|---|
(package private) ProxyPreparer |
NormServerInitializer.leasePreparer |
private ProxyPreparer |
NormServerBaseImpl.leasePreparer
Proxy preparer for leases supplied through the API
|
(package private) ProxyPreparer |
NormServerInitializer.listenerPreparer |
private ProxyPreparer |
NormServerBaseImpl.listenerPreparer
Proxy preparer for listeners supplied through the API
|
(package private) ProxyPreparer |
NormServerInitializer.locatorPreparer |
private ProxyPreparer |
NormServerBaseImpl.locatorPreparer
Proxy preparer for lookup locators supplied through the API, and not
including initial lookup locators.
|
(package private) ProxyPreparer |
NormServerInitializer.recoveredLeasePreparer |
private ProxyPreparer |
NormServerBaseImpl.recoveredLeasePreparer
Proxy preparer for leases recovered from persistent storage, or null if
not persistent.
|
private ProxyPreparer |
ClientLeaseWrapper.recoveredLeasePreparer
The proxy preparer to use to prepare a newly unmarshalled client lease,
or null if this instance was created using an already prepared client
lease, which is how instances are created initially.
|
(package private) ProxyPreparer |
NormServerInitializer.recoveredListenerPreparer |
private ProxyPreparer |
NormServerBaseImpl.recoveredListenerPreparer
Proxy preparer for listeners recovered from persistent storage, or null
if not persistent.
|
(package private) ProxyPreparer |
NormServerInitializer.recoveredLocatorPreparer |
private ProxyPreparer |
NormServerBaseImpl.recoveredLocatorPreparer
Proxy preparer for lookup locators recovered from persistent storage, or
null if not persistent.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
ClientLeaseWrapper.recoverTransient(List renewedList,
UIDGenerator generator,
LeaseSet leaseSet,
ProxyPreparer recoveredLeasePreparer)
After recovering a lease wrapper call this method before using
any other of the wrappers methods and before allocating any new
wrappers can not recover itself.
|
(package private) Iterator |
LeaseSet.restoreTransientState(EventTypeGenerator generator,
PersistentStore store,
NormServerBaseImpl normServerBaseImpl,
ProxyPreparer recoveredListenerPreparer)
Restore the transient state of the set that can't be restored
automatically after a log recovery.
|
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
EventType.recoveredListenerPreparer
The proxy preparer to use to prepare a newly unmarshalled listener, or
null if this instance was created using an already prepared listener,
which is how instances are created initially.
|
Modifier and Type | Method and Description |
---|---|
void |
EventType.restoreTransientState(EventTypeGenerator generator,
SendMonitor monitor,
ProxyPreparer recoveredListenerPreparer)
Restore the transient state of this object after recovering it
from a serialization stream.
|
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
JoinState.recoveredLookupLocatorPreparer
Proxy preparer for recovered lookup locators
|
Constructor and Description |
---|
JoinState(Object service,
LeaseRenewalManager lrm,
Configuration config,
Entry[] serviceAttributes,
ProxyPreparer recoveredLookupLocatorPreparer,
ServiceID serviceID)
Simple constructor.
|
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
OutriggerServerImpl.listenerPreparer
ProxyPreparer for event listeners |
(package private) ProxyPreparer |
OutriggerServerImpl.InitHolder.listenerPreparer |
private ProxyPreparer |
JoinStateManager.lookupLocatorPreparer
ProxyPreparer for LookupLocators |
private ProxyPreparer |
TxnTable.proxyPreparer
ProxyPreparer to use when unpacking transactions, may be
null . |
private ProxyPreparer |
OutriggerServerImpl.recoveredListenerPreparer
ProxyPreparer for event listeners
that get recovered from the store. |
(package private) ProxyPreparer |
OutriggerServerImpl.InitHolder.recoveredListenerPreparer |
private ProxyPreparer |
Notifier.recoveredListenerPreparer
Proxy preparer to use on recovered listeners
|
private ProxyPreparer |
OutriggerServerImpl.recoveredTransactionManagerPreparer
ProxyPreparer for transaction managers
that get recovered from the store. |
(package private) ProxyPreparer |
OutriggerServerImpl.InitHolder.recoveredTransactionManagerPreparer |
private ProxyPreparer |
OutriggerServerImpl.transactionManagerPreparer
ProxyPreparer for transaction managers |
(package private) ProxyPreparer |
OutriggerServerImpl.InitHolder.transactionManagerPreparer |
Modifier and Type | Method and Description |
---|---|
(package private) ProxyPreparer |
OutriggerServerImpl.getRecoveredTransactionManagerPreparer()
Return the proxy preparer for recovered transaction
managers, or
null if there is none. |
Modifier and Type | Method and Description |
---|---|
Object |
StorableReference.get(ProxyPreparer preparer)
Return the proxy.
|
(package private) RemoteEventListener |
TransactableEventWatcher.getListener(ProxyPreparer preparer) |
(package private) RemoteEventListener |
TransactableAvailabilityWatcher.getListener(ProxyPreparer preparer) |
(package private) RemoteEventListener |
StorableEventWatcher.getListener(ProxyPreparer preparer) |
(package private) RemoteEventListener |
StorableAvailabilityWatcher.getListener(ProxyPreparer preparer) |
(package private) abstract RemoteEventListener |
EventRegistrationWatcher.getListener(ProxyPreparer preparer)
Return the remote listener associated with this
EventRegistrationWatcher . |
(package private) abstract RemoteEventListener |
AvailabilityRegistrationWatcher.getListener(ProxyPreparer preparer)
Return the remote listener associated with this
EventRegistrationWatcher . |
ServerTransaction |
Txn.getTransaction(ProxyPreparer preparer) |
ServerTransaction |
TransactableMgr.getTransaction(ProxyPreparer preparer)
Return the
ServerTransaction which this manager
handles. |
void |
EventSender.sendEvent(JavaSpace source,
long now,
ProxyPreparer preparer)
Send a remote event to the encapsulated listener of the encapsulated
type, with the encapsulated handback, sequence number.
|
void |
EventRegistrationWatcher.BasicEventSender.sendEvent(JavaSpace source,
long now,
ProxyPreparer preparer) |
void |
AvailabilityRegistrationWatcher.VisibilityEventSender.sendEvent(JavaSpace source,
long now,
ProxyPreparer preparer) |
Constructor and Description |
---|
Notifier(JavaSpace source,
ProxyPreparer recoveredListenerPreparer,
Configuration config)
Create a notifier connected to the given
space . |
TxnTable(ProxyPreparer proxyPreparer)
Create a new
TxnTable . |
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
Activation.groupPreparer
preparer for ActivationInstantiators
|
private static ProxyPreparer |
AbstractActivationGroup.monPreparer
monitor proxy preparer
|
Modifier and Type | Method and Description |
---|---|
private static ProxyPreparer |
Activation.getPreparer(Configuration config,
String name)
Return a ProxyPreparer configuration entry.
|
private static ProxyPreparer |
AbstractActivationGroup.getPreparer(Configuration config,
String name)
Return a ProxyPreparer configuration entry.
|
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
RegistrarImpl.listenerPreparer
Preparer for received remote event listeners
|
(package private) ProxyPreparer |
RegistrarImpl.Initializer.listenerPreparer |
private ProxyPreparer |
RegistrarImpl.locatorPreparer
Preparer for received lookup locators
|
(package private) ProxyPreparer |
RegistrarImpl.Initializer.locatorPreparer |
private ProxyPreparer |
RegistrarImpl.recoveredListenerPreparer
Preparer for remote event listeners recovered from state log
|
(package private) ProxyPreparer |
RegistrarImpl.Initializer.recoveredListenerPreparer |
private ProxyPreparer |
RegistrarImpl.recoveredLocatorPreparer
Preparer for lookup locators recovered from state log
|
(package private) ProxyPreparer |
RegistrarImpl.Initializer.recoveredLocatorPreparer |
Modifier and Type | Method and Description |
---|---|
(package private) void |
RegistrarImpl.EventReg.prepareListener(ProxyPreparer preparer)
Prepares listener (if non-null) using the given proxy preparer.
|
private static LookupLocator[] |
RegistrarImpl.prepareLocators(LookupLocator[] locators,
ProxyPreparer preparer,
boolean tolerateFailures)
Returns new array containing locators from the given non-null array
prepared using the given proxy preparer.
|
Modifier and Type | Field and Description |
---|---|
private ProxyPreparer |
SharedActivatableServiceDescriptor.innerProxyPreparer |
private ProxyPreparer |
NonActivatableServiceDescriptor.servicePreparer |
Modifier and Type | Method and Description |
---|---|
ProxyPreparer |
SharedActivatableServiceDescriptor.getInnerProxyPreparer()
ProxyPreparer accessor method. |
ProxyPreparer |
NonActivatableServiceDescriptor.getServicePreparer()
ProxyPreparer accessor method. |
Modifier and Type | Method and Description |
---|---|
void |
SharedActivatableServiceDescriptor.setInnerProxyPreparer(ProxyPreparer pp)
Sets the inner
ProxyPreparer for this descriptor. |
void |
NonActivatableServiceDescriptor.setServicePreparer(ProxyPreparer serviceProxyPreparer)
Sets the
ProxyPreparer for this descriptor. |
Constructor and Description |
---|
NonActivatableServiceDescriptor(String exportCodebase,
String policy,
String importCodebase,
String implClassName,
Configuration config,
LifeCycle lifeCycle,
ProxyPreparer preparer) |
NonActivatableServiceDescriptor(String exportCodebase,
String policy,
String importCodebase,
String implClassName,
String[] serverConfigArgs,
LifeCycle lifeCycle,
ProxyPreparer preparer)
Main constructor.
|
NonActivatableServiceDescriptor(String exportCodebase,
String policy,
String importCodebase,
String implClassName,
String[] serverConfigArgs,
ProxyPreparer preparer)
Convenience constructor.
|
SharedActivatableServiceDescriptor(String exportCodebase,
String policy,
String importCodebase,
String implClassName,
String sharedGroupLog,
String[] serverConfigArgs,
ProxyPreparer innerProxyPreparer,
ProxyPreparer outerProxyPreparer,
boolean restart)
Convenience constructor.
|
SharedActivatableServiceDescriptor(String exportCodebase,
String policy,
String importCodebase,
String implClassName,
String sharedGroupLog,
String[] serverConfigArgs,
ProxyPreparer innerProxyPreparer,
ProxyPreparer outerProxyPreparer,
boolean restart,
String host,
int port)
Main constructor.
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.