org.globus.wsrf.impl
Class ResourceHomeImpl

java.lang.Object
  org.globus.wsrf.impl.ResourceHomeImpl

All Implemented Interfaces:

Destroyable, Initializable, ResourceHome

Direct Known Subclasses:

EnumResourceHome, NotificationConsumerHome, SecurityContextHome, SubscriptionHome

public abstract class ResourceHomeImpl

extends java.lang.Object

implements ResourceHome, Initializable, Destroyable

An implementation of the ResourceHome interface. This implementation was designed to work with resources that implement the PersistenceCallback interface as well as memory resident resources. If the resource class implements the PersistenceCallback interface SoftReferences will be used to recycle resource objects. The resource class implementation is responsible for saving its state to disk. This implementation will not call PersistenceCallback.store(). The resource implementation must have a default constructor.

Configuration options:

• sweeperDelay - configures how often the resource sweeper runs in msec. By default the resource sweeper runs every minute. For example:

      <parameter>
       <name>sweeperDelay</name>
       <value>60000</value>
      </parameter>
   

• resourceClass - configures the name of the resource class. For example:

      <parameter>
       <name>resourceClass</name>
       <value>org.globus.wsrf.samples.counter.PersistentCounter</value>
      </parameter>
   

• resourceKeyType - configures the key type class. By default java.lang.String is used. For example:

      <parameter>
       <name>resourceKeyType</name>
       <value>java.lang.Integer</value>
      </parameter>
   

• resourceKeyName - configures the key name. For example:

      <parameter>
       <name>resourceKeyName</name>
       <value>{http://counter.com}CounterKey</value>
      </parameter>
   

Note: Must be deployed with org.globus.wsrf.jndi.BeanFactory in JNDI or user must first call initialize() method. Also when overriding the initialize() method make sure to call super.initialize();.

Note: This ResourceHome implementation performs per key synchronization.

Nested Class Summary

private static class

ResourceHomeImpl.Sweeper This ResourceSweeper implementation just returns the resources currently stored in the map.

Field Summary

protected Cache	cache
protected java.lang.String	cacheLocation
private static org.globus.util.I18n	i18n
private boolean	initialized
protected java.lang.Class	keyTypeClass
protected javax.xml.namespace.QName	keyTypeName
protected LockManager	lockManager
private static org.apache.commons.logging.Log	logger
protected java.lang.Class	resourceClass
protected java.lang.reflect.Constructor	resourceConstructor
protected boolean	resourceIsPersistent
protected java.util.Map	resources
private ResourceHomeImpl.Sweeper	sweeper
private long	sweeperDelay

Constructor Summary

ResourceHomeImpl()

Method Summary

protected void	add(ResourceKey key, Resource resource)
private void	addResource(ResourceKey key, Resource resource)
protected Resource	createNewInstance()
protected Resource	createNewInstanceAndLoad(ResourceKey key)
void	destroy()
Resource	find(ResourceKey key) Retrives a resource.
private Resource	get(ResourceKey key)
java.lang.String	getCacheLocation()
java.lang.Class	getKeyTypeClass() The resource key type.
javax.xml.namespace.QName	getKeyTypeName() The name of the resource key.
java.lang.String	getResourceClass()
long	getSweeperDelay()
void	initialize()
private void	initResourceConstructor()
void	remove(ResourceKey key) Removes a resource.
void	setCacheLocation(java.lang.String jndiLocation)
void	setResourceClass(java.lang.String clazz)
void	setResourceKeyName(java.lang.String keyName)
void	setResourceKeyType(java.lang.String clazz)
void	setSweeperDelay(long delay)

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

i18n

private static org.globus.util.I18n i18n

resources

protected java.util.Map resources

keyTypeName

protected javax.xml.namespace.QName keyTypeName

resourceClass

protected java.lang.Class resourceClass

keyTypeClass

protected java.lang.Class keyTypeClass

resourceIsPersistent

protected boolean resourceIsPersistent

resourceConstructor

protected java.lang.reflect.Constructor resourceConstructor

lockManager

protected LockManager lockManager

cacheLocation

protected java.lang.String cacheLocation

cache

protected Cache cache

sweeperDelay

private long sweeperDelay

sweeper

private ResourceHomeImpl.Sweeper sweeper

initialized

private boolean initialized

Constructor Detail

ResourceHomeImpl

public ResourceHomeImpl()

Method Detail

setResourceClass

public void setResourceClass(java.lang.String clazz)
                      throws java.lang.ClassNotFoundException

Throws:

java.lang.ClassNotFoundException

getResourceClass

public java.lang.String getResourceClass()

setResourceKeyType

public void setResourceKeyType(java.lang.String clazz)
                        throws java.lang.ClassNotFoundException

Throws:

java.lang.ClassNotFoundException

getKeyTypeClass

public java.lang.Class getKeyTypeClass()

Description copied from interface: ResourceHome

The resource key type. The ResourceKey used or passed to this ResourceHome must have match this type (corresponds to ResourceKey.getValue()).

Specified by:

getKeyTypeClass in interface ResourceHome

Returns:

the type of the key.

setResourceKeyName

public void setResourceKeyName(java.lang.String keyName)

getKeyTypeName

public javax.xml.namespace.QName getKeyTypeName()

Description copied from interface: ResourceHome

The name of the resource key. The ResourceKey used or passed to this ResourceHome must have match this name (corresponds to ResourceKey.getName()).

Specified by:

getKeyTypeName in interface ResourceHome

Returns:

the name of the key.

setSweeperDelay

public void setSweeperDelay(long delay)

getSweeperDelay

public long getSweeperDelay()

setCacheLocation

public void setCacheLocation(java.lang.String jndiLocation)

getCacheLocation

public java.lang.String getCacheLocation()

initialize

public void initialize()
                throws java.lang.Exception

Specified by:

initialize in interface Initializable

Throws:

java.lang.Exception

initResourceConstructor

private void initResourceConstructor()
                              throws java.lang.Exception

Throws:

java.lang.Exception

createNewInstance

protected Resource createNewInstance()
                              throws ResourceException

Throws:

ResourceException

createNewInstanceAndLoad

protected Resource createNewInstanceAndLoad(ResourceKey key)
                                     throws ResourceException

Throws:

ResourceException

find

public Resource find(ResourceKey key)
              throws ResourceException

Description copied from interface: ResourceHome

Retrives a resource. Note: This function must not return null. It must return the resource object or throw an exception if there is no resource with the specified key.

Specified by:

find in interface ResourceHome

Returns:

non-null resource object.

Throws:

ResourceException - if any other error occurs.

get

private Resource get(ResourceKey key)
              throws ResourceException

Throws:

ResourceException

remove

public void remove(ResourceKey key)
            throws ResourceException

Removes a resource. If the resource implements the RemoveCallback interface the RemoveCallback.remove() operation will be called. The RemoveCallback.remove() operation is called under a reentrant lock. Therefore, a RemoveCallback.remove() implementation might perform ResourceHome.find() on itself from the same thread but will deadlock if done from another thread.

Specified by:

remove in interface ResourceHome

Throws:

NoSuchResourceException - if no resource exists with the given key

InvalidResourceKeyException - if the resource key is invalid.

RemoveNotSupportedException - if remove operation is not supported.

ResourceException - if any other error occurs.

add

protected void add(ResourceKey key,
                   Resource resource)

addResource

private void addResource(ResourceKey key,
                         Resource resource)

destroy

public void destroy()

Specified by:

destroy in interface Destroyable