Package | Description |
---|---|
net.jini.core.lookup |
These are the lookup service interfaces and classes.
|
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.
|
org.apache.river.config |
Defines convenience classes for writing
configuration files and accessing Configuration entries. |
org.apache.river.discovery |
Provides a set of constraints, low-level utility classes, and provider
interfaces for participating in versions 1 and 2 of the multicast request,
multicast announcement, and unicast discovery protocols.
|
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.norm.lookup | |
org.apache.river.outrigger |
This is an implementation of a JavaSpaces technology-enabled service.
|
org.apache.river.reggie |
Provides implementations of
ServiceRegistrar . |
Modifier and Type | Field and Description |
---|---|
ServiceID |
ServiceTemplate.serviceID
Service ID to match, or null.
|
ServiceID |
ServiceItem.serviceID
A service ID, or null if registering for the first time.
|
protected ServiceID |
ServiceEvent.serviceID
ServiceID of the item that triggered the event.
|
Modifier and Type | Method and Description |
---|---|
ServiceID |
ServiceRegistration.getServiceID()
Returns the service ID for this service.
|
ServiceID |
ServiceRegistrar.getServiceID()
Returns the service ID of the lookup service.
|
ServiceID |
ServiceEvent.getServiceID()
Returns the serviceID of the item that triggered the event.
|
Constructor and Description |
---|
ServiceEvent(Object source,
long eventID,
long seqNo,
MarshalledObject handback,
ServiceID serviceID,
int transition)
Simple constructor.
|
ServiceItem(ServiceID serviceID,
Object service,
Entry[] attrSets)
Simple constructor.
|
ServiceTemplate(ServiceID serviceID,
Class[] serviceTypes,
Entry[] attrSetTemplates)
Simple constructor.
|
Modifier and Type | Field and Description |
---|---|
protected ServiceID |
IncomingMulticastAnnouncement.serviceID
The ServiceID that has been announced.
|
protected ServiceID[] |
IncomingMulticastRequest.serviceIDs
The ServiceIDs from which the requestor has already heard.
|
Modifier and Type | Field and Description |
---|---|
protected Map<ServiceID,String> |
RemoteDiscoveryEvent.groups
Map from the service IDs of the registrars of this event
to the groups in which each registrar is a member. |
private java.util.concurrent.ConcurrentMap<ServiceID,AbstractLookupDiscovery.AnnouncementInfo> |
AbstractLookupDiscovery.regInfo
Map from ServiceID to multicast announcement time stamps; used by the
process that monitors multicast announcements from already-discovered
lookup services, and determines when those announcements have stopped.
|
private Map<ServiceID,UnicastResponse> |
AbstractLookupDiscovery.registrars
Map from ServiceID to UnicastResponse.
|
Modifier and Type | Method and Description |
---|---|
ServiceID |
IncomingMulticastAnnouncement.getServiceID()
Return the ServiceID of the announcing lookup service.
|
ServiceID[] |
IncomingMulticastRequest.getServiceIDs()
Return a set of ServiceIDs from which the requestor has already
heard.
|
private ServiceID[] |
AbstractLookupDiscovery.getServiceIDs()
Returns the service IDs of the lookup service(s) discovered to date.
|
Modifier and Type | Method and Description |
---|---|
Map<ServiceID,String> |
RemoteDiscoveryEvent.getGroups()
Returns a set that maps to the service ID of each registrar referenced
by this event, the current set of groups in which each registrar is a
member.
|
Modifier and Type | Method and Description |
---|---|
static DatagramPacket[] |
OutgoingMulticastRequest.marshal(int responsePort,
String[] groups,
ServiceID[] heard)
Using the default maximum packet size, marshal a multicast request
into one or more datagram packets.
|
static DatagramPacket[] |
OutgoingMulticastRequest.marshal(int responsePort,
String[] groups,
ServiceID[] heard,
int maxPacketSize)
Using the given maximum packet size, marshal a multicast request
into one or more datagram packets.
|
static DatagramPacket[] |
OutgoingMulticastAnnouncement.marshal(ServiceID id,
LookupLocator loc,
String[] groups)
Marshal a multicast announcement into one or more datagram
packets.
|
Modifier and Type | Field and Description |
---|---|
private ServiceID |
ServiceDiscoveryManager.LookupCacheImpl.ServiceDiscardTimerTask.serviceID |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentMap<ServiceID,java.util.concurrent.Future> |
ServiceDiscoveryManager.LookupCacheImpl.serviceDiscardFutures |
private java.util.concurrent.ConcurrentMap<ServiceID,ServiceDiscoveryManager.ServiceItemReg> |
ServiceDiscoveryManager.LookupCacheImpl.serviceIdMap |
Modifier and Type | Method and Description |
---|---|
private Iterator<Map.Entry<ServiceID,ServiceDiscoveryManager.ServiceItemReg>> |
ServiceDiscoveryManager.LookupCacheImpl.getServiceIdMapEntrySetIterator() |
Modifier and Type | Method and Description |
---|---|
private void |
ServiceDiscoveryManager.LookupCacheImpl.cancelDiscardTask(ServiceID sid)
Wake up service discard task if running, else remove from mgr.
|
private ServiceItem |
ServiceDiscoveryManager.LookupCacheImpl.filterMaybeDiscard(ServiceID srvcID,
ServiceDiscoveryManager.ServiceItemReg itemReg,
ServiceItem item,
boolean sendEvent)
Applies the first-stage
filter associated with the
current instance of LookupCache to the given
item and returns the resulting filtered item if the
filter is passed (or is null ); otherwise,
returns null and sends a service removed event if the
sendEvent parameter is true . |
private ServiceItem |
ServiceDiscoveryManager.LookupCacheImpl.findItem(ServiceID sid,
ServiceItem[] items)
Returns the element in the given items array having the given
ServiceID.
|
private void |
ServiceDiscoveryManager.LookupCacheImpl.handleMatchNoMatch(ServiceRegistrar proxy,
ServiceID srvcID)
Convenience method called (only
when a TRANSITION_MATCH_NOMATCH event is received) that removes the
given
item from the serviceIdMap and wakes
up the ServiceDiscardTimerTask if the given
item is discarded; otherwise, sends a removed event. |
private void |
ServiceDiscoveryManager.LookupCacheImpl.itemMatchMatchChange(ServiceID srvcID,
ServiceDiscoveryManager.ServiceItemReg itemReg,
ServiceRegistrar proxy,
ServiceItem newItem,
boolean matchMatchEvent)
With respect to a given service (referenced by the parameter
newItem), if either an event has been received from the given lookup
service (referenced by the proxy parameter), or a snapshot of the
given lookup service's state has been retrieved, this method
determines whether the service's attributes have changed, or whether
a new version of the service has been registered.
|
private void |
ServiceDiscoveryManager.LookupCacheImpl.notifyServiceMap(Object eventSource,
long eventID,
long seqNo,
ServiceID sid,
ServiceItem item,
int transition)
Called by the lookupListener's notify() method.
|
private boolean |
ServiceDiscoveryManager.LookupCacheImpl.removeServiceIdMapSendNoEvent(ServiceID sid,
ServiceDiscoveryManager.ServiceItemReg itemReg)
Removes an entry in the serviceIdMap, but sends no notification.
|
void |
ServiceIDListener.serviceIDNotify(ServiceID serviceID)
Called when the JoinManager gets a valid ServiceID from a lookup
service.
|
Constructor and Description |
---|
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceID serviceID,
DiscoveryManagement discoveryMgr,
LeaseRenewalManager leaseMgr)
Constructs an instance of this class that will register the
service with all discovered lookup services, using the supplied
ServiceID . |
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceID serviceID,
DiscoveryManagement discoveryMgr,
LeaseRenewalManager leaseMgr,
Configuration config)
Constructs an instance of this class, configured using the items
retrieved through the given
Configuration , that will
register the service with all discovered lookup services, using the
supplied ServiceID . |
JoinManager(Object serviceProxy,
Entry[] attrSets,
ServiceID serviceID,
ServiceIDListener callback,
JoinManager.Conf conf)
Convenience method invoked by the constructors of this class that
uses the given
Configuration to initialize the current
instance of this utility, and initiates all join processing for
the given parameters. |
ServiceDiscardTimerTask(ServiceDiscoveryManager.LookupCacheImpl cache,
ServiceID serviceID) |
Modifier and Type | Method and Description |
---|---|
static ServiceID |
ConfigUtil.createServiceID(String s)
Returns a
ServiceID constructed from a 128-bit value
represented by a string. |
Modifier and Type | Field and Description |
---|---|
private ServiceID |
MulticastAnnouncement.serviceID
The lookup service ID.
|
private ServiceID[] |
MulticastRequest.serviceIDs
The IDs of known lookup services.
|
Modifier and Type | Method and Description |
---|---|
ServiceID |
MulticastAnnouncement.getServiceID()
Returns the service ID of the lookup service.
|
ServiceID[] |
MulticastRequest.getServiceIDs()
Returns the service IDs of known lookup services.
|
Constructor and Description |
---|
MulticastAnnouncement(long sequenceNumber,
String host,
int port,
String[] groups,
ServiceID serviceID)
Creates a new
MulticastAnnouncement instance containing the
given values. |
MulticastRequest(String host,
int port,
String[] groups,
ServiceID[] serviceIDs)
Creates a new
MulticastRequest instance containing the
given values. |
Modifier and Type | Field and Description |
---|---|
(package private) ServiceID |
Browser.RegistrarMenuItem.id |
Constructor and Description |
---|
RegistrarMenuItem(String host,
ServiceID id) |
Modifier and Type | Field and Description |
---|---|
private ServiceID |
FiddlerImpl.serviceID
The service ID associated with this service when it is registered
with any lookup service.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
JoinStateManager.startManager(Configuration config,
Object service,
ServiceID serviceID,
Entry[] baseAttributes)
Start the manager.
|
Modifier and Type | Field and Description |
---|---|
private ServiceID |
JoinState.serviceID
The service ID, derived from the service's UUID.
|
Constructor and Description |
---|
JoinState(Object service,
LeaseRenewalManager lrm,
Configuration config,
Entry[] serviceAttributes,
ProxyPreparer recoveredLookupLocatorPreparer,
ServiceID serviceID)
Simple constructor.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
JoinStateManager.startManager(Configuration config,
LogOps log,
Object service,
ServiceID serviceID,
Entry[] baseAttributes)
Start the manager.
|
Modifier and Type | Field and Description |
---|---|
private ServiceID |
RegistrarImpl.myServiceID
Our service ID
|
(package private) ServiceID |
RegistrarProxy.registrarID
The registrar's service ID.
|
(package private) ServiceID |
RegistrarLeaseMap.registrarID
The registrar's service ID.
|
(package private) ServiceID |
RegistrarLease.registrarID
The registrar's service ID.
|
private ServiceID |
ProxyVerifier.registrarID
The registrar's service ID, used for comparison with registrar service
IDs extracted from smart proxies to verify.
|
(package private) ServiceID |
AdminProxy.registrarID
The registrar's service ID.
|
ServiceID |
Template.serviceID
ServiceTemplate.serviceID
|
(package private) ServiceID |
ServiceLease.serviceID
The service id assigned at registration.
|
private ServiceID |
RegistrarImpl.AttrsAddedLogObj.serviceID
The service id.
|
private ServiceID |
RegistrarImpl.AttrsModifiedLogObj.serviceID
The service id.
|
private ServiceID |
RegistrarImpl.AttrsSetLogObj.serviceID
The service id.
|
private ServiceID |
RegistrarImpl.ServiceLeaseCancelledLogObj.serviceID
The service id.
|
private ServiceID |
RegistrarImpl.ServiceLeaseRenewedLogObj.serviceID
The service id.
|
ServiceID |
Item.serviceID
ServiceItem.serviceID.
|
private ServiceID |
RegistrarEvent.servID
The service ID of the serviceItem that triggered the event.
|
private ServiceID |
RegistrarImpl.EventTask.sid
The service id
|
Modifier and Type | Field and Description |
---|---|
private Map<ServiceID,RegistrarImpl.SvcReg> |
RegistrarImpl.serviceByID
Map from ServiceID to SvcReg.
|
private Map<String,Map<ServiceID,RegistrarImpl.SvcReg>> |
RegistrarImpl.serviceByTypeName
Map from String to HashMap mapping ServiceID to SvcReg.
|
private Map<ServiceID,Object> |
RegistrarImpl.subEventByService
Map from ServiceID to EventReg or EventReg[].
|
Modifier and Type | Method and Description |
---|---|
(package private) ServiceID |
RegistrarLease.getRegistrarID()
Returns the registrar's service ID.
|
(package private) ServiceID |
ServiceLease.getServiceID()
Returns the service ID
|
ServiceID |
Registration.getServiceID() |
ServiceID |
RegistrarProxy.getServiceID() |
ServiceID |
RegistrarEvent.getServiceID() |
private ServiceID |
RegistrarImpl.newServiceID()
Generate a new service ID
|
Modifier and Type | Method and Description |
---|---|
void |
RegistrarImpl.addAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets) |
void |
Registrar.addAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets)
Adds the specified attribute sets (those that aren't duplicates of
existing attribute sets) to the registered service item.
|
private void |
RegistrarImpl.addAttributesDo(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets)
The code that does the real work of addAttributes.
|
void |
RegistrarImpl.cancelServiceLease(ServiceID serviceID,
Uuid leaseID) |
void |
Registrar.cancelServiceLease(ServiceID serviceID,
Uuid leaseID)
Cancels a service lease.
|
private void |
RegistrarImpl.cancelServiceLeaseDo(ServiceID serviceID,
Uuid leaseID)
The code that does the real work of cancelServiceLease.
|
private RegistrarImpl.SvcReg |
RegistrarImpl.checkLease(ServiceID serviceID,
Uuid leaseID,
long now) |
(package private) static void |
Util.checkRegistrantServiceID(ServiceID serviceID,
Logger logger,
Level level)
Checks if the value of the given service ID to register conforms to the
ServiceID specification, logging a message to the provided logger at the
specified logging level if it doesn't.
|
private void |
RegistrarImpl.generateEvent(RegistrarImpl.EventReg reg,
Item pre,
Item post,
ServiceID sid,
long now)
Generate an event if the event registration matches.
|
(package private) static RegistrarProxy |
RegistrarProxy.getInstance(Registrar server,
ServiceID registrarID)
Returns RegistrarProxy or ConstrainableRegistrarProxy instance,
depending on whether given server implements RemoteMethodControl.
|
(package private) static AdminProxy |
AdminProxy.getInstance(Registrar server,
ServiceID registrarID)
Returns AdminProxy or ConstrainableAdminProxy instance, depending on
whether given server implements RemoteMethodControl.
|
(package private) static EventLease |
EventLease.getInstance(Registrar server,
ServiceID registrarID,
long eventID,
Uuid leaseID,
long expiration)
Returns EventLease or ConstrainableEventLease instance, depending on
whether given server implements RemoteMethodControl.
|
(package private) static ServiceLease |
ServiceLease.getInstance(Registrar server,
ServiceID registrarID,
ServiceID serviceID,
Uuid leaseID,
long expiration)
Returns ServiceLease or ConstrainableServiceLease instance, depending on
whether given server implements RemoteMethodControl.
|
void |
RegistrarImpl.modifyAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSetTmpls,
EntryRep[] attrSets) |
void |
Registrar.modifyAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSetTmpls,
EntryRep[] attrSets)
Modifies existing attribute sets of a registered service item.
|
private void |
RegistrarImpl.modifyAttributesDo(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSetTmpls,
EntryRep[] attrSets)
The code that does the real work of modifyAttributes.
|
private void |
RegistrarImpl.pendingEvent(RegistrarImpl.EventReg reg,
ServiceID sid,
Item item,
int transition,
long now)
Add a pending EventTask for this event registration.
|
long |
RegistrarImpl.renewServiceLease(ServiceID serviceID,
Uuid leaseID,
long renewDuration) |
long |
Registrar.renewServiceLease(ServiceID serviceID,
Uuid leaseID,
long duration)
Renews a service lease.
|
private void |
RegistrarImpl.renewServiceLeaseAbs(ServiceID serviceID,
Uuid leaseID,
long renewExpiration)
Renew the service lease for an absolute expiration time.
|
private long |
RegistrarImpl.renewServiceLeaseDo(ServiceID serviceID,
Uuid leaseID,
long renewDuration)
The code that does the real work of renewServiceLease.
|
private long |
RegistrarImpl.renewServiceLeaseInt(ServiceID serviceID,
Uuid leaseID,
long renewDuration,
long now)
Renew a service lease for a relative duration from now.
|
void |
RegistrarImpl.setAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets) |
void |
Registrar.setAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets)
Deletes all of the service item's existing attributes, and replaces
them with the specified attribute sets.
|
private void |
RegistrarImpl.setAttributesDo(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets)
The code that does the real work of setAttributes.
|
Constructor and Description |
---|
AdminProxy(Registrar server,
ServiceID registrarID)
Constructor for use by getInstance(), ConstrainableAdminProxy.
|
AttrsAddedLogObj(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets)
Simple constructor
|
AttrsModifiedLogObj(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSetTmpls,
EntryRep[] attrSets)
Simple constructor
|
AttrsSetLogObj(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets)
Simple constructor
|
ConstrainableAdminProxy(Registrar server,
ServiceID registrarID,
MethodConstraints constraints)
Creates new ConstrainableAdminProxy with given server reference, service
ID and client constraints.
|
ConstrainableEventLease(Registrar server,
ServiceID registrarID,
long eventID,
Uuid leaseID,
long expiration,
MethodConstraints constraints)
Creates new ConstrainableEventLease with given server reference, event
and lease IDs, expiration time and client constraints.
|
ConstrainableRegistrarProxy(Registrar server,
ServiceID registrarID,
MethodConstraints constraints)
Creates new ConstrainableRegistrarProxy with given server reference,
service ID and client constraints.
|
ConstrainableServiceLease(Registrar server,
ServiceID registrarID,
ServiceID serviceID,
Uuid leaseID,
long expiration,
MethodConstraints constraints)
Creates new ConstrainableServiceLease with given server reference, event
and lease IDs, expiration time and client constraints.
|
EventLease(Registrar server,
ServiceID registrarID,
long eventID,
Uuid leaseID,
long expiration)
Constructor for use by getInstance(), ConstrainableEventLease.
|
EventTask(RegistrarImpl.EventReg reg,
ServiceID sid,
Item item,
int transition,
RegistrarProxy proxy,
Registrar registrar,
long now)
Simple constructor, except increments reg.seqNo.
|
Item(ServiceID serviceID,
ServiceType serviceType,
String codebase,
MarshalledWrapper service,
EntryRep[] attrSets) |
ProxyVerifier(Registrar server,
ServiceID registrarID)
Constructs proxy verifier which compares server references extracted
from smart proxies with the given canonical server reference, which must
implement both RemoteMethodControl and TrustEquivalence.
|
RegistrarEvent(Object source,
long eventID,
long seqNo,
MarshalledObject handback,
ServiceID serviceID,
int transition,
Item item)
Simple constructor.
|
RegistrarLease(Registrar server,
ServiceID registrarID,
Uuid leaseID,
long expiration)
Simple constructor.
|
RegistrarProxy(Registrar server,
ServiceID registrarID)
Constructor for use by getInstance(), ConstrainableRegistrarProxy.
|
ServiceLease(Registrar server,
ServiceID registrarID,
ServiceID serviceID,
Uuid leaseID,
long expiration)
Constructor for use by getInstance(), ConstrainableServiceLease.
|
ServiceLeaseCancelledLogObj(ServiceID serviceID,
Uuid leaseID)
Simple constructor
|
ServiceLeaseRenewedLogObj(ServiceID serviceID,
Uuid leaseID,
long leaseExpTime)
Simple constructor
|
Copyright 2007-2013, multiple authors.
Licensed under the Apache License, Version 2.0, see the NOTICE file for attributions.