org.globus.exec.service.exec
Class StagingListener

java.lang.Object
  org.globus.exec.service.exec.StagingListener

All Implemented Interfaces:

NotifyCallback

public class StagingListener

extends java.lang.Object

implements NotifyCallback

This thread class is needed for use be StateMachine to avoid a race condition between the JobStateMonitor.dispatchEvent() and JobStateMonitor.unregisterJobID() methods.

Field Summary

protected static java.util.Hashtable	execJobMap
private static org.globus.util.I18n	i18n
private static StagingListener	INSTANCE
(package private) static org.apache.commons.logging.Log	logger Log4J logger
private static java.util.Hashtable	statusMap

Constructor Summary

private

StagingListener()

Method Summary

void	deliver(java.util.List topicPath, org.apache.axis.message.addressing.EndpointReferenceType producerEndpoint, java.lang.Object messageWrapper)
private static java.lang.String	endpointToKey(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint)
static StagingListener	getInstance()
(package private) static java.lang.String	getLoggingPrefix(ResourceKey execJobKey, java.lang.String transferJobKey)
static org.globus.rft.generated.RequestStatusType	getNextStatus(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint)
static StagingListener	registerTransferJob(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint, ResourceKey execJobKey)
static void	unregisterTransferJob(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint)

Methods inherited from class java.lang.Object

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

Field Detail

logger

static org.apache.commons.logging.Log logger

Log4J logger

i18n

private static org.globus.util.I18n i18n

INSTANCE

private static StagingListener INSTANCE

execJobMap

protected static java.util.Hashtable execJobMap

statusMap

private static java.util.Hashtable statusMap

Constructor Detail

StagingListener

private StagingListener()

Method Detail

getInstance

public static StagingListener getInstance()

registerTransferJob

public static StagingListener registerTransferJob(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint,
                                                  ResourceKey execJobKey)

unregisterTransferJob

public static void unregisterTransferJob(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint)

getNextStatus

public static org.globus.rft.generated.RequestStatusType getNextStatus(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint)

deliver

public void deliver(java.util.List topicPath,
                    org.apache.axis.message.addressing.EndpointReferenceType producerEndpoint,
                    java.lang.Object messageWrapper)

Specified by:

deliver in interface NotifyCallback

endpointToKey

private static java.lang.String endpointToKey(org.apache.axis.message.addressing.EndpointReferenceType transferJobEndpoint)

getLoggingPrefix

static java.lang.String getLoggingPrefix(ResourceKey execJobKey,
                                         java.lang.String transferJobKey)