org.globus.exec.service.test.throughput.util
Class NotificationHandler

java.lang.Object
  org.globus.exec.service.test.throughput.util.NotificationHandler

All Implemented Interfaces:

GramJobListener, NotifyCallback

public class NotificationHandler
extends java.lang.Object
implements NotifyCallback, GramJobListener

Processes notification messages. Implements NotifyCallback and GramJobListener to be able to work with both stubs and GramJob

Field Summary

private JobManager	jobManager
private org.apache.commons.logging.Log	log
private TaskController	taskController

Constructor Summary

NotificationHandler(Test tpTest)

Method Summary

void	deliver(java.util.List topicPath, org.globus.axis.message.addressing.EndpointReferenceType jobEpr, java.lang.Object message) From interface NotifyCallback.
private void	handleNotificationMessage(org.globus.axis.message.addressing.EndpointReferenceType jobEpr, StateEnumeration state, FaultType[] faults) Process the notification message
void	stateChanged(GramJob job) From interface GramJobListener.

Methods inherited from class java.lang.Object

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

Field Detail

log

private org.apache.commons.logging.Log log

jobManager

private JobManager jobManager

taskController

private TaskController taskController

Constructor Detail

NotificationHandler

public NotificationHandler(Test tpTest)

Method Detail

deliver

public void deliver(java.util.List topicPath,
                    org.globus.axis.message.addressing.EndpointReferenceType jobEpr,
                    java.lang.Object message)

From interface NotifyCallback.

Specified by:

deliver in interface NotifyCallback

stateChanged

public void stateChanged(GramJob job)

From interface GramJobListener. GramJob objects calls this method when a notification message is received.

Specified by:

stateChanged in interface GramJobListener

handleNotificationMessage

private void handleNotificationMessage(org.globus.axis.message.addressing.EndpointReferenceType jobEpr,
                                       StateEnumeration state,
                                       FaultType[] faults)

Process the notification message

Parameters:

producerEpr -

state -