org.globus.mds.index.impl
Class IndexResource
java.lang.Object
org.globus.mds.aggregator.impl.AggregatorServiceGroupResource
org.globus.mds.index.impl.IndexResource
- All Implemented Interfaces:
- Resource, ResourceProperties, ServiceGroupRegistrationResource, ServiceGroupResource, TopicListAccessor
- public class IndexResource
- extends AggregatorServiceGroupResource
- implements TopicListAccessor
Resource Implementation of an Index resource.
Each index resource maintains an aggregation of resource properties
from other resources that have been registered to it.
all of this index must remain in memory at all time.
| Methods inherited from class org.globus.mds.aggregator.impl.AggregatorServiceGroupResource |
addAggregatorSource, decrementCurrent, getConfiguration, getCurrentRegCount, getKey, getLifetimeRegTotal, getResourcePropertySet, incrementCurrent, incrementTotal, init, iterateEntryKeys, iterateEntryValues, loadCompatibleSources, notifyChange, serviceGroupAdd, setVersion |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
private static org.apache.commons.logging.Log logger
resourceKey
private ResourceKey resourceKey
consumerManager
static NotificationConsumerManager consumerManager
RP_SET
public static final javax.xml.namespace.QName RP_SET
terminationTime
protected java.util.Calendar terminationTime
propSet
private ResourcePropertySet propSet
topicList
private TopicList topicList
strings
private java.lang.String[] strings
IndexResource
public IndexResource()
setResourceKey
public void setResourceKey(ResourceKey k)
throws java.lang.Exception
- Used to inform the resource of its key.
- Throws:
java.lang.Exception
getResourceKey
public ResourceKey getResourceKey()
setTerminationTime
public void setTerminationTime(java.util.Calendar time)
getTerminationTime
public java.util.Calendar getTerminationTime()
getCurrentTime
public java.util.Calendar getCurrentTime()
getTopicList
public TopicList getTopicList()
- Specified by:
getTopicList in interface TopicListAccessor
getConsumer
public org.apache.axis.message.addressing.EndpointReferenceType getConsumer(NotifyCallback callback)
- returns an EPR to a newly created consumer, such that notifications
sent to this consumer will be delivered to the callback.
initializeAggregator
private void initializeAggregator()
throws java.lang.Exception
- Throws:
java.lang.Exception