org.globus.mds.index.impl
Class IndexResource

java.lang.Object
  extended byorg.globus.mds.aggregator.impl.AggregatorServiceGroupResource
      extended byorg.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.


Nested Class Summary
 
Nested classes inherited from class org.globus.mds.aggregator.impl.AggregatorServiceGroupResource
 
Field Summary
(package private) static NotificationConsumerManager consumerManager
           
private static org.apache.commons.logging.Log logger
           
private  ResourcePropertySet propSet
           
private  ResourceKey resourceKey
           
static javax.xml.namespace.QName RP_SET
           
private  java.lang.String[] strings
           
protected  java.util.Calendar terminationTime
           
private  TopicList topicList
           
 
Fields inherited from class org.globus.mds.aggregator.impl.AggregatorServiceGroupResource
DEFAULT_SWEEP_PERIOD, REGISTRATION_COUNT_RP
 
Constructor Summary
IndexResource()
           
 
Method Summary
 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.
 java.util.Calendar getCurrentTime()
           
 ResourceKey getResourceKey()
           
 java.util.Calendar getTerminationTime()
           
 TopicList getTopicList()
           
private  void initializeAggregator()
           
 void setResourceKey(ResourceKey k)
          Used to inform the resource of its key.
 void setTerminationTime(java.util.Calendar 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
 

Field Detail

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
Constructor Detail

IndexResource

public IndexResource()
Method Detail

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