public class GigaRegistrar extends Object implements Registrar, ProxyAccessor, ServerProxyTrust, com.gigaspaces.lrmi.nio.info.NIOInfoProvider, com.gigaspaces.internal.os.OSInfoProvider, com.gigaspaces.internal.jvm.JVMInfoProvider, com.gigaspaces.grid.zone.GridZoneProvider, com.gigaspaces.grid.gsa.AgentIdAware, com.gigaspaces.internal.log.InternalLogProvider, com.gigaspaces.internal.dump.InternalDumpProvider
| Constructor and Description |
|---|
GigaRegistrar(String[] configArgs,
LifeCycle lifeCycle)
Constructs RegistrarImpl based on a configuration obtained using the
provided string arguments.
|
| Modifier and Type | Method and Description |
|---|---|
void |
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.
|
void |
addLookupAttributes(Entry[] attrSets)
Add attribute sets for the service.
|
void |
addLookupGroups(String[] groups)
Add new groups to the set to join.
|
void |
addLookupLocators(LookupLocator[] locators)
Add locators for specific new lookup services to join.
|
void |
addMemberGroups(String[] groups)
Adds the given set of names to the set whose elements are the names
of the groups in which the lookup service is currently a member.
|
void |
cancelEventLease(long eventID,
Uuid leaseID)
Cancels an event lease.
|
Exception[] |
cancelLeases(Object[] regIDs,
Uuid[] leaseIDs)
Cancels service and event leases from a LeaseMap.
|
void |
cancelServiceLease(ServiceID serviceID,
Uuid leaseID)
Cancels a service lease.
|
void |
destroy()
Destroy the service, if possible, including its persistent storage.
|
void |
disableLRMIMonitoring() |
byte[] |
dumpBytes(String file,
long from,
int length) |
void |
enableLRMIMonitoring() |
com.gigaspaces.lrmi.LRMIMonitoringDetails |
fetchLRMIMonitoringDetails() |
com.gigaspaces.internal.dump.InternalDumpResult |
generateDump(String cause,
Map<String,Object> context) |
com.gigaspaces.internal.dump.InternalDumpResult |
generateDump(String cause,
Map<String,Object> context,
String... contributors) |
Object |
getAdmin()
Returns an object that implements whatever administration interfaces
are appropriate for the particular service.
|
int |
getAgentId() |
long |
getCurrentTimestamp() |
EntryClassBase[] |
getEntryClasses(Template tmpl)
Looks at all service items that match the specified template, finds
every entry (among those service items) that either doesn't match any
entry templates or is a subclass of at least one matching entry
template, and returns the set of the (most specific) classes of those
entries.
|
Object[] |
getFieldValues(Template tmpl,
int setIndex,
int field)
Looks at all service items that match the specified template, finds
every entry (among those service items) that matches
tmpl.attributeSetTemplates[setIndex], and returns the set of values
of the specified field of those entries.
|
String |
getGSAServiceID() |
com.gigaspaces.internal.jvm.JVMDetails |
getJVMDetails() |
com.gigaspaces.internal.jvm.JVMStatistics |
getJVMStatistics() |
LookupLocator |
getLocator()
Returns a LookupLocator that can be used if necessary for unicast
discovery of the lookup service.
|
Entry[] |
getLookupAttributes()
Get the current attribute sets for the service.
|
String[] |
getLookupGroups()
Get the list of groups to join.
|
LookupLocator[] |
getLookupLocators()
Get the list of locators of specific lookup services to join.
|
String[] |
getMemberGroups()
Returns an array consisting of the names of the groups in which the
lookup service is a member.
|
com.gigaspaces.lrmi.nio.info.NIODetails |
getNIODetails() |
com.gigaspaces.lrmi.nio.info.NIOStatistics |
getNIOStatistics() |
com.gigaspaces.internal.os.OSDetails |
getOSDetails() |
com.gigaspaces.internal.os.OSStatistics |
getOSStatistics() |
Object |
getProxy()
Returns a proxy object for this remote object.
|
TrustVerifier |
getProxyVerifier()
Returns a
TrustVerifier that can be used to verify that
a proxy can be trusted as a proxy for the service; that is, the
isTrustedObject method of the
returned verifier can be called with a candidate proxy. |
Object |
getServiceProxy()
Returns a proxy object for this object.
|
ServiceTypeBase[] |
getServiceTypes(Template tmpl,
String prefix)
Looks at all service items that match the specified template, and for
every service item finds the most specific type (class or interface)
or types the service item is an instance of that are neither equal to,
nor a superclass of, any of the service types in the template and that
have names that start with the specified prefix, and returns the set
of all such types.
|
int |
getUnicastPort()
Returns the port number on which the lookup service listens for
unicast discovery queries.
|
String[] |
getZones() |
static boolean |
isActive() |
LogEntries |
logEntriesDirect(LogEntryMatcher matcher) |
MarshalledWrapper |
lookup(Template tmpl)
Returns the service object (i.e., just ServiceItem.service) from an
item matching the template, or null if there is no match.
|
Matches |
lookup(Template tmpl,
int maxMatches)
Returns at most maxMatches items matching the template, plus the total
number of items that match the template.
|
void |
modifyAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSetTmpls,
EntryRep[] attrSets)
Modifies existing attribute sets of a registered service item.
|
void |
modifyLookupAttributes(Entry[] attrSetTemplates,
Entry[] attrSets)
Modify the current attribute sets, using the same semantics as
ServiceRegistration.modifyAttributes.
|
RegistrarEventRegistration |
notify(Template tmpl,
int transitions,
RemoteEventListener listener,
MarshalledObject handback,
long leaseDuration)
Registers for event notification.
|
RegistrarEventRegistration |
notify(Template tmpl,
int transitions,
RemoteEventListener listener,
MarshalledObject handback,
long leaseDuration,
int notifyType)
Registers for event notification.
|
ServiceRegistration |
register(Item nitem,
long leaseDuration)
Register a new service or re-register an existing service.
|
void |
reloadMetricConfiguration() |
void |
removeLookupGroups(String[] groups)
Remove groups from the set to join.
|
void |
removeLookupLocators(LookupLocator[] locators)
Remove locators for specific lookup services from the set to join.
|
void |
removeMemberGroups(String[] groups)
Deletes the elements of the given set of names from the set whose
elements are the names of the groups in which the lookup service is
currently a member.
|
long |
renewEventLease(long eventID,
Uuid leaseID,
long renewDuration)
Renews an event lease.
|
RenewResults |
renewLeases(Object[] regIDs,
Uuid[] leaseIDs,
long[] renewDurations)
Renews service and event leases from a LeaseMap.
|
long |
renewServiceLease(ServiceID serviceID,
Uuid leaseID,
long renewDuration)
Renews a service lease.
|
void |
runGc() |
ServiceDetails |
serviceDetails(ServiceID serviceID)
Returns the service details of the service id.
|
void |
setAttributes(ServiceID serviceID,
Uuid leaseID,
EntryRep[] attrSets)
Deletes all of the service item's existing attributes, and replaces
them with the specified attribute sets.
|
void |
setLookupGroups(String[] groups)
Replace the list of groups to join with a new list.
|
void |
setLookupLocators(LookupLocator[] locators)
Replace the list of locators of specific lookup services to join
with a new list.
|
void |
setMemberGroups(String[] groups)
Replaces the set whose elements are the names of the groups in which
the lookup service is currently a member with the given set of group
names.
|
void |
setUnicastPort(int port)
Changes the number of the port on which the lookup service is currently
listening for unicast discovery queries to the given port number.
|
public GigaRegistrar(String[] configArgs, LifeCycle lifeCycle) throws Exception
Exceptionpublic static boolean isActive()
public Object getServiceProxy() throws NoSuchObjectException
ServiceProxyAccessornull.getServiceProxy in interface ServiceProxyAccessorNoSuchObjectExceptionpublic Object getProxy()
ProxyAccessornull is returned.getProxy in interface ProxyAccessornullpublic TrustVerifier getProxyVerifier() throws NoSuchObjectException
ServerProxyTrustTrustVerifier that can be used to verify that
a proxy can be trusted as a proxy for the service; that is, the
isTrustedObject method of the
returned verifier can be called with a candidate proxy. The verifier
should be able to verify all proxies for the service, including
proxies for resources (such as leases and registrations).getProxyVerifier in interface ServerProxyTrustTrustVerifier that can be used to verify that
a proxy can be trusted as a proxy for the serviceNoSuchObjectExceptionpublic ServiceRegistration register(Item nitem, long leaseDuration) throws NoSuchObjectException
Registrarregister in interface RegistrarNoSuchObjectExceptionServiceRegistrar.register(net.jini.core.lookup.ServiceItem, long)public ServiceDetails serviceDetails(ServiceID serviceID) throws RemoteException
RegistrarserviceDetails in interface RegistrarRemoteExceptionpublic MarshalledWrapper lookup(Template tmpl) throws NoSuchObjectException
Registrarlookup in interface RegistrarNoSuchObjectExceptionServiceRegistrar.lookup(net.jini.core.lookup.ServiceTemplate)public Matches lookup(Template tmpl, int maxMatches) throws NoSuchObjectException
Registrarlookup in interface RegistrarNoSuchObjectExceptionServiceRegistrar.lookup(net.jini.core.lookup.ServiceTemplate)public RegistrarEventRegistration notify(Template tmpl, int transitions, RemoteEventListener listener, MarshalledObject handback, long leaseDuration) throws RemoteException
Registrarnotify in interface RegistrarRemoteExceptionServiceRegistrar.notify(net.jini.core.lookup.ServiceTemplate, int, net.jini.core.event.RemoteEventListener, java.rmi.MarshalledObject, long)public RegistrarEventRegistration notify(Template tmpl, int transitions, RemoteEventListener listener, MarshalledObject handback, long leaseDuration, int notifyType) throws RemoteException
Registrarnotify in interface RegistrarRemoteExceptionServiceRegistrar.notify(net.jini.core.lookup.ServiceTemplate, int, net.jini.core.event.RemoteEventListener, java.rmi.MarshalledObject, long)public EntryClassBase[] getEntryClasses(Template tmpl) throws NoSuchObjectException
RegistrargetEntryClasses in interface RegistrarNoSuchObjectExceptionServiceRegistrar.getEntryClasses(net.jini.core.lookup.ServiceTemplate)public Object[] getFieldValues(Template tmpl, int setIndex, int field) throws NoSuchObjectException
RegistrargetFieldValues in interface RegistrarNoSuchObjectExceptionServiceRegistrar.getFieldValues(net.jini.core.lookup.ServiceTemplate, int, java.lang.String)public ServiceTypeBase[] getServiceTypes(Template tmpl, String prefix) throws NoSuchObjectException
RegistrargetServiceTypes in interface RegistrarNoSuchObjectExceptionServiceRegistrar.getServiceTypes(net.jini.core.lookup.ServiceTemplate, java.lang.String)public LookupLocator getLocator() throws NoSuchObjectException
RegistrargetLocator in interface RegistrarNoSuchObjectExceptionServiceRegistrar.getLocator()public Object getAdmin() throws NoSuchObjectException
AdministrablegetAdmin in interface AdministrableNoSuchObjectExceptionJoinAdminpublic void addAttributes(ServiceID serviceID, Uuid leaseID, EntryRep[] attrSets) throws NoSuchObjectException, UnknownLeaseException
RegistraraddAttributes in interface RegistrarNoSuchObjectExceptionUnknownLeaseExceptionServiceRegistration.addAttributes(net.jini.core.entry.Entry[])public void modifyAttributes(ServiceID serviceID, Uuid leaseID, EntryRep[] attrSetTmpls, EntryRep[] attrSets) throws NoSuchObjectException, UnknownLeaseException
RegistrarmodifyAttributes in interface RegistrarNoSuchObjectExceptionUnknownLeaseExceptionServiceRegistration.modifyAttributes(net.jini.core.entry.Entry[], net.jini.core.entry.Entry[])public void setAttributes(ServiceID serviceID, Uuid leaseID, EntryRep[] attrSets) throws NoSuchObjectException, UnknownLeaseException
RegistrarsetAttributes in interface RegistrarNoSuchObjectExceptionUnknownLeaseExceptionServiceRegistration.setAttributes(net.jini.core.entry.Entry[])public void cancelServiceLease(ServiceID serviceID, Uuid leaseID) throws NoSuchObjectException, UnknownLeaseException
RegistrarcancelServiceLease in interface RegistrarNoSuchObjectExceptionUnknownLeaseExceptionLease.cancel()public long renewServiceLease(ServiceID serviceID, Uuid leaseID, long renewDuration) throws NoSuchObjectException, UnknownLeaseException
RegistrarrenewServiceLease in interface RegistrarNoSuchObjectExceptionUnknownLeaseExceptionLease.renew(long)public void cancelEventLease(long eventID,
Uuid leaseID)
throws NoSuchObjectException,
UnknownLeaseException
RegistrarcancelEventLease in interface RegistrarNoSuchObjectExceptionUnknownLeaseExceptionLease.cancel()public long renewEventLease(long eventID,
Uuid leaseID,
long renewDuration)
throws NoSuchObjectException,
UnknownLeaseException
RegistrarrenewEventLease in interface RegistrarNoSuchObjectExceptionUnknownLeaseExceptionLease.renew(long)public RenewResults renewLeases(Object[] regIDs, Uuid[] leaseIDs, long[] renewDurations) throws NoSuchObjectException
RegistrarrenewLeases in interface RegistrarNoSuchObjectExceptionLeaseMap.renewAll()public Exception[] cancelLeases(Object[] regIDs, Uuid[] leaseIDs) throws NoSuchObjectException
RegistrarcancelLeases in interface RegistrarNoSuchObjectExceptionLeaseMap.cancelAll()public Entry[] getLookupAttributes() throws NoSuchObjectException
JoinAdmingetLookupAttributes in interface JoinAdminNoSuchObjectExceptionpublic void addLookupAttributes(Entry[] attrSets) throws RemoteException
JoinAdminaddLookupAttributes in interface JoinAdminattrSets - the attribute sets to addRemoteExceptionpublic void modifyLookupAttributes(Entry[] attrSetTemplates, Entry[] attrSets) throws RemoteException
JoinAdminmodifyLookupAttributes in interface JoinAdminattrSetTemplates - the templates for matching attribute setsattrSets - the modifications to make to matching setsRemoteExceptionServiceRegistration.modifyAttributes(net.jini.core.entry.Entry[], net.jini.core.entry.Entry[])public String[] getLookupGroups() throws NoSuchObjectException
JoinAdmingetLookupGroups in interface JoinAdminNoSuchObjectExceptionJoinAdmin.setLookupGroups(java.lang.String[])public void addLookupGroups(String[] groups) throws NoSuchObjectException
JoinAdminaddLookupGroups in interface JoinAdmingroups - groups to joinNoSuchObjectExceptionJoinAdmin.removeLookupGroups(java.lang.String[])public void removeLookupGroups(String[] groups) throws NoSuchObjectException
JoinAdminremoveLookupGroups in interface JoinAdmingroups - groups to leaveNoSuchObjectExceptionJoinAdmin.addLookupGroups(java.lang.String[])public void setLookupGroups(String[] groups) throws NoSuchObjectException
JoinAdminsetLookupGroups in interface JoinAdmingroups - groups to joinNoSuchObjectExceptionJoinAdmin.getLookupGroups()public LookupLocator[] getLookupLocators() throws NoSuchObjectException
JoinAdmingetLookupLocators in interface JoinAdminNoSuchObjectExceptionJoinAdmin.setLookupLocators(net.jini.core.discovery.LookupLocator[])public void addLookupLocators(LookupLocator[] locators) throws RemoteException
JoinAdminaddLookupLocators in interface JoinAdminlocators - locators of specific lookup services to joinRemoteExceptionJoinAdmin.removeLookupLocators(net.jini.core.discovery.LookupLocator[])public void removeLookupLocators(LookupLocator[] locators) throws RemoteException
JoinAdminremoveLookupLocators in interface JoinAdminlocators - locators of specific lookup services to leaveRemoteExceptionJoinAdmin.addLookupLocators(net.jini.core.discovery.LookupLocator[])public void setLookupLocators(LookupLocator[] locators) throws RemoteException
JoinAdminsetLookupLocators in interface JoinAdminlocators - locators of specific lookup services to joinRemoteExceptionJoinAdmin.getLookupLocators()public void addMemberGroups(String[] groups) throws NoSuchObjectException
DiscoveryAdminNO_GROUPS) is input, this method takes no action.addMemberGroups in interface DiscoveryAdmingroups - String array consisting of the names of
the new, additional groups in which the lookup service
is to be a member.NoSuchObjectExceptionpublic void removeMemberGroups(String[] groups) throws NoSuchObjectException
DiscoveryAdminNO_GROUPS) is input, this
method takes no action.removeMemberGroups in interface DiscoveryAdmingroups - String array consisting of the names to
remove from the set whose elements are the names of the
groups in which the lookup service is currently a member.NoSuchObjectExceptionpublic String[] getMemberGroups() throws NoSuchObjectException
DiscoveryAdmingetMemberGroups in interface DiscoveryAdminString array consisting of the names of the groups
in which the lookup service is a memberNoSuchObjectExceptionpublic void setMemberGroups(String[] groups) throws NoSuchObjectException
DiscoveryAdminNO_GROUPS)
is input, then the lookup service will be a member of no groups.setMemberGroups in interface DiscoveryAdmingroups - String array consisting of the names of
the new groups in which the lookup service is to be a
member.NoSuchObjectExceptionpublic int getUnicastPort()
throws NoSuchObjectException
DiscoveryAdmingetUnicastPort in interface DiscoveryAdminint representing the port number on which the
lookup service listens for unicast discovery queries.NoSuchObjectExceptionpublic void setUnicastPort(int port)
throws IOException
DiscoveryAdminsetUnicastPort in interface DiscoveryAdminport - int representing the new port number on which
the lookup service should listen for unicast discovery
queries.IOException - because an invocation of this method will
result in the re-initiation of the unicast discovery process,
which can throw an IOException when socket
allocation occurs.RemoteException - typically, this exception occurs when
there is a communication failure between the client and the
server.public void destroy()
throws RemoteException
DestroyAdmindestroy in interface DestroyAdminRemoteExceptionpublic int getAgentId()
throws RemoteException
getAgentId in interface com.gigaspaces.grid.gsa.AgentIdAwareRemoteExceptionpublic String getGSAServiceID() throws RemoteException
getGSAServiceID in interface com.gigaspaces.grid.gsa.AgentIdAwareRemoteExceptionpublic com.gigaspaces.lrmi.nio.info.NIODetails getNIODetails()
throws RemoteException
getNIODetails in interface com.gigaspaces.lrmi.nio.info.NIOInfoProviderRemoteExceptionpublic com.gigaspaces.lrmi.nio.info.NIOStatistics getNIOStatistics()
throws RemoteException
getNIOStatistics in interface com.gigaspaces.lrmi.nio.info.NIOInfoProviderRemoteExceptionpublic void enableLRMIMonitoring()
throws RemoteException
enableLRMIMonitoring in interface com.gigaspaces.lrmi.nio.info.NIOInfoProviderRemoteExceptionpublic void disableLRMIMonitoring()
throws RemoteException
disableLRMIMonitoring in interface com.gigaspaces.lrmi.nio.info.NIOInfoProviderRemoteExceptionpublic com.gigaspaces.lrmi.LRMIMonitoringDetails fetchLRMIMonitoringDetails()
throws RemoteException
fetchLRMIMonitoringDetails in interface com.gigaspaces.lrmi.nio.info.NIOInfoProviderRemoteExceptionpublic long getCurrentTimestamp()
throws RemoteException
getCurrentTimestamp in interface com.gigaspaces.internal.os.OSInfoProviderRemoteExceptionpublic com.gigaspaces.internal.os.OSDetails getOSDetails()
throws RemoteException
getOSDetails in interface com.gigaspaces.internal.os.OSInfoProviderRemoteExceptionpublic com.gigaspaces.internal.os.OSStatistics getOSStatistics()
throws RemoteException
getOSStatistics in interface com.gigaspaces.internal.os.OSInfoProviderRemoteExceptionpublic com.gigaspaces.internal.jvm.JVMDetails getJVMDetails()
throws RemoteException
getJVMDetails in interface com.gigaspaces.internal.jvm.JVMInfoProviderRemoteExceptionpublic com.gigaspaces.internal.jvm.JVMStatistics getJVMStatistics()
throws RemoteException
getJVMStatistics in interface com.gigaspaces.internal.jvm.JVMInfoProviderRemoteExceptionpublic void runGc()
throws RemoteException
runGc in interface com.gigaspaces.internal.jvm.JVMInfoProviderRemoteExceptionpublic String[] getZones() throws RemoteException
getZones in interface com.gigaspaces.grid.zone.GridZoneProviderRemoteExceptionpublic LogEntries logEntriesDirect(LogEntryMatcher matcher) throws RemoteException, IOException
logEntriesDirect in interface com.gigaspaces.internal.log.InternalLogProviderRemoteExceptionIOExceptionpublic void reloadMetricConfiguration()
throws RemoteException
reloadMetricConfiguration in interface com.gigaspaces.internal.dump.InternalDumpProviderRemoteExceptionpublic com.gigaspaces.internal.dump.InternalDumpResult generateDump(String cause, Map<String,Object> context) throws RemoteException, com.gigaspaces.internal.dump.InternalDumpException
generateDump in interface com.gigaspaces.internal.dump.InternalDumpProviderRemoteExceptioncom.gigaspaces.internal.dump.InternalDumpExceptionpublic com.gigaspaces.internal.dump.InternalDumpResult generateDump(String cause, Map<String,Object> context, String... contributors) throws RemoteException, com.gigaspaces.internal.dump.InternalDumpException
generateDump in interface com.gigaspaces.internal.dump.InternalDumpProviderRemoteExceptioncom.gigaspaces.internal.dump.InternalDumpExceptionpublic byte[] dumpBytes(String file, long from, int length) throws RemoteException, IOException
dumpBytes in interface com.gigaspaces.internal.dump.InternalDumpProviderRemoteExceptionIOExceptionCopyright © GigaSpaces.