org.globus.ogsa.impl.core.notification.framework.test
Class CounterNotificationTestCase

java.lang.Object
  TestCase
      org.globus.ogsa.server.test.GridTestCase
          org.globus.ogsa.impl.core.notification.framework.test.CounterNotificationTestCase

All Implemented Interfaces:

NotificationSinkCallback, ServiceProperties

Direct Known Subclasses:

TestNotification, TestNotificationWithXPath, TestSubscriptionMinInterval

public abstract class CounterNotificationTestCase

extends GridTestCase

implements NotificationSinkCallback

See Also:

Serialized Form

Field Summary

protected org.w3c.dom.Element	message
protected Semaphore	semaphore
protected java.lang.String	sinkHandle
protected NotificationSinkManager	sinkManager

Fields inherited from class org.globus.ogsa.server.test.GridTestCase

TEST_SERVER

Fields inherited from interface org.globus.ogsa.ServiceProperties

ACTIVATE_ON_STARTUP, ACTIVATION, BASE_CLASS_NAME, BOOTSTRAP, CONFIG_PATH, CONTAINS_REFERENCE, CREATION_EXTENSIBILITY, CREATION_EXTENSIBILITY_OUTPUT, CUSTOM_EXTENSIBILITY_DESERIALIZER, CUSTOM_EXTENSIBILITY_SERIALIZER, CUSTOM_MAPPING_REGISTERED, DEACTIVATED_PERSISTENT, DEACTIVATED_STATE, DEACTIVATED_TRANSIENT, DEACTIVATION, DESTROY_LISTENER, DESTRUCTION_SKELETON, DISABLE_FACTORY_REGISTRY, ENDPOINT, ENTRY_INSTANCE_CREATION, FACTORY, FACTORY_CALLBACK, FACTORY_HANDLE, FACTORY_PROVIDER, FACTORY_REGISTRY, GSR_DESCRIPTION, HANDLE, HANDLE_PORT, HANDLE_PROTOCOL, INSTANCE_CLASS, INSTANCE_DEACTIVATION, INSTANCE_GSR_DESCRIPTION, INSTANCE_LIFECYCLE, INSTANCE_PORT_TYPE, INSTANCE_PORT_TYPE_NS, INSTANCE_PREFIX, INSTANCE_REGISTRY, INSTANCE_SCHEMA_PATH, INSTANCE_WSDL, INTERFACE_CLASS_NAME, INVOCATION_ID, LAZY_CREATION, LIFECYCLE, LIFECYCLE_MONITOR, LIFECYCLE_MONITOR_CLASS, NAME, NOTIFICATION_ENGINE, NOTIFICATION_FACTORY, NOTIFICATION_SOURCE, OPERATION_PROVIDERS, PERSISTENT, PERSISTENT_PROPERTIES, PORT, PORT_TYPE, PORT_TYPE_NS, PRIMARY_KEY, PROTOCOL, QUERY_ENGINE, REDIRECT_RESOLVER, REGISTRY, RESOLVER_CACHE, ROUTER_HEADER, ROUTER_VIA, SCHEMA_LOCATION, SCHEMA_PATH, SERVICE_ACTIVATOR, SERVICE_DATA, SERVICE_DEPLOYMENT, SERVICE_GROUP_ENTRY, SERVICE_GROUP_PROVIDER, SERVICE_LOADER, SERVICE_NODE, SERVICE_PATH, SINK_ID, STARTUP_STATE, SWEEP_SERVICE_DATA, TIMEOUT, TIMESTAMP, TRANSIENT, TYPE, USER, WEBSTART_PANEL_NAME, WEBSTART_URL, WSDL

Constructor Summary

CounterNotificationTestCase(java.lang.String name)

Method Summary

protected void	checkMessage(int counterValue)
protected void	createSubscription(QName[] sdQNames, java.util.Calendar timeout, HandleType sourceHandle, NotificationSinkCallback callback, ExtensibilityType aExtensibilityType)
void	deliverNotification(ExtensibilityType any)
void	flush() gives a hint that this property should be checkpointed to the deployment descriptor, it is however not guaranteed that the properties have been persisted when the method returns
protected CounterPortType	getCounterService()
protected GSR	getCounterServiceReference()
java.lang.Object	getPersistentProperty(java.lang.String key) gets a persistent property (checkpointed to deployment descriptor) keyed by name
java.lang.Object	getProperty(java.lang.String key) gets a property keyed by name
protected java.lang.String	getSinkHandle()
protected NotificationSinkManager	getSinkManager()
protected void	internalTestCreate()
void	setPersistentProperty(java.lang.String key, java.lang.Object obj) sets a persistent property (checkpointed to deployment descriptor) keyed by name
void	setProperty(java.lang.String key, java.lang.Object obj) sets a property keyed by name
protected void	setUp()
protected abstract void	setupSink()
static void	sleepFor(int secs) Method sleepFor.
protected void	tearDown()
protected void	updateCounterValue(int i) Method updateCounterValue.

Methods inherited from class org.globus.ogsa.server.test.GridTestCase

setTestServer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

sinkManager

protected NotificationSinkManager sinkManager

sinkHandle

protected java.lang.String sinkHandle

message

protected org.w3c.dom.Element message

semaphore

protected Semaphore semaphore

Constructor Detail

CounterNotificationTestCase

public CounterNotificationTestCase(java.lang.String name)

Method Detail

setupSink

protected abstract void setupSink()
                           throws java.lang.Exception

Throws:

java.lang.Exception

setUp

protected void setUp()
              throws java.lang.Exception

Overrides:

setUp in class GridTestCase

Throws:

java.lang.Exception

tearDown

protected void tearDown()
                 throws java.lang.Exception

Throws:

java.lang.Exception

internalTestCreate

protected void internalTestCreate()
                           throws java.lang.Exception

Throws:

java.lang.Exception

getSinkManager

protected NotificationSinkManager getSinkManager()
                                          throws java.lang.Exception

Throws:

java.lang.Exception

sleepFor

public static void sleepFor(int secs)

Method sleepFor.

Parameters:

secs - - seconds to sleep.

createSubscription

protected void createSubscription(QName[] sdQNames,
                                  java.util.Calendar timeout,
                                  HandleType sourceHandle,
                                  NotificationSinkCallback callback,
                                  ExtensibilityType aExtensibilityType)
                           throws java.lang.Exception

Throws:

java.lang.Exception

getSinkHandle

protected java.lang.String getSinkHandle()

getCounterServiceReference

protected GSR getCounterServiceReference()

getCounterService

protected CounterPortType getCounterService()

updateCounterValue

protected void updateCounterValue(int i)

Method updateCounterValue.

Parameters:

i -

checkMessage

protected void checkMessage(int counterValue)

setProperty

public void setProperty(java.lang.String key,
                        java.lang.Object obj)

Description copied from interface: ServiceProperties

sets a property keyed by name

Specified by:

setProperty in interface ServiceProperties

Parameters:

key - property key

obj - property value, if null the property will be removed (if it exists)

setPersistentProperty

public void setPersistentProperty(java.lang.String key,
                                  java.lang.Object obj)

Description copied from interface: ServiceProperties

sets a persistent property (checkpointed to deployment descriptor) keyed by name

Specified by:

setPersistentProperty in interface ServiceProperties

Parameters:

key - property key

obj - property value, if null the property will be removed (if it exists)

getProperty

public java.lang.Object getProperty(java.lang.String key)

Description copied from interface: ServiceProperties

gets a property keyed by name

Specified by:

getProperty in interface ServiceProperties

Parameters:

key - property key

Returns:

property value or null

getPersistentProperty

public java.lang.Object getPersistentProperty(java.lang.String key)

Description copied from interface: ServiceProperties

gets a persistent property (checkpointed to deployment descriptor) keyed by name

Specified by:

getPersistentProperty in interface ServiceProperties

Parameters:

key - property key

Returns:

property value or null

flush

public void flush()

Description copied from interface: ServiceProperties

gives a hint that this property should be checkpointed to the deployment descriptor, it is however not guaranteed that the properties have been persisted when the method returns

Specified by:

flush in interface ServiceProperties

deliverNotification

public void deliverNotification(ExtensibilityType any)
                         throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException