org.globus.transfer.reliable.client
Class ReliableFileTransferJob

java.lang.Object
  org.globus.transfer.reliable.client.ReliableFileTransferJob

All Implemented Interfaces:

NotifyCallback

public class ReliableFileTransferJob

extends Object

implements NotifyCallback

Field Summary

private Authorization	authorization
private static String	BASE_SERVICE_PATH
private ClientSecurityDescriptor	clientSecurityDescriptor
private NotificationConsumerManager	consumer
private org.globus.gsi.GlobusCredential	credential
private static Authorization	DEFAULT_AUTHZ
static Integer	DEFAULT_MSG_PROTECTION
private static String	DEFAULT_SECURITY_TYPE
protected EndpointReferenceType	delegationEpr
private String	delegationEprFile
private String	endpointType
private int	failedCount
private BaseFaultType	fault
private int	finishedCount
private String	host
private Vector	listeners
private Integer	msgProtectionType
private org.globus.rft.generated.OverallStatus	overallStatus
private String	port
private org.globus.rft.generated.RequestStatusType	requestStatusRP
private static String	RFT_FACTORY
private static String	RFT_SERVICE
private EndpointReferenceType	rftEndpointReferenceType
private String	rftEprFile
private org.globus.rft.generated.ReliableFileTransferFactoryPortType	rftFactoryPort
private String	rftFactoryUrl
private org.globus.rft.generated.ReliableFileTransferPortType	rftPortType
private org.globus.rft.generated.BaseRequestType	rftRequest
private String	rftServiceUrl
private String	securityType
private String	status
private boolean	subscribedForRequestStatus
private int	terminationTime
private int	transferCount
private boolean	verbose

Constructor Summary

ReliableFileTransferJob()

ReliableFileTransferJob(org.globus.rft.generated.BaseRequestType rftRequest)

Method Summary

void	addListener(TransferStatusListener listener)
EndpointReferenceType	create()
void	deliver(List topicPath, EndpointReferenceType producer, Object message)
void	destroy()
Authorization	getAuthorization()
ClientSecurityDescriptor	getClientSecurityDescriptor()
org.globus.gsi.GlobusCredential	getCredential()
EndpointReferenceType	getDelegationEpr()
String	getDelegationEprFile()
String	getEndpointType()
int	getFailedCount()
BaseFaultType	getFault()
BaseFaultType	getFaultFromRP(org.globus.rft.generated.RFTFaultResourcePropertyType faultRP)
int	getFinishedCount()
String	getHost()
Integer	getMsgProtectionType()
org.globus.rft.generated.OverallStatus	getOverallStatus()
String	getPort()
EndpointReferenceType	getRftEPR()
String	getRftEprFile()
org.globus.rft.generated.ReliableFileTransferFactoryPortType	getRFTFactoryPort()
String	getRFTFactoryUrl()
org.globus.rft.generated.ReliableFileTransferPortType	getRFTPort()
org.globus.rft.generated.BaseRequestType	getRFTRequest()
String	getRFTServiceUrl()
String	getSecurityType()
String	getStatus()
int	getTerminationTime()
int	getTransferCount()
boolean	getVerbose()
void	removeListener(TransferStatusListener listener)
void	setAuthorization(Authorization authorization)
void	setClientSecurityDescriptor(ClientSecurityDescriptor clientSecurityDescriptor)
void	setCredential(org.globus.gsi.GlobusCredential credential)
void	setDelegationEpr(EndpointReferenceType delegationEpr)
void	setDelegationEprFile(String delegationEprFile)
void	setEndpointType(String endpointType)
void	setFailedCount(int failedCount)
void	setFinishedCount(int finishedCount)
void	setHost(String host)
void	setMsgProtectionType(Integer msgProtectionType)
void	setOverallStatus(org.globus.rft.generated.OverallStatus overallStatus)
void	setPort(String port)
void	setRftEprFile(String rftEprFile)
void	setRFTFactoryUrl(String rftFactoryUrl)
void	setRFTRequest(org.globus.rft.generated.BaseRequestType rftRequest)
void	setRFTServiceUrl(String rftServiceUrl)
void	setSecurityOnStub(Stub stub)
void	setSecurityType(String securityType)
void	setTerminationTime(int terminationTime)
void	setTransferCount(int transferCount)
void	setVerbose(boolean verbose)
org.globus.rft.generated.StartOutputType	start()
private void	subscribe(QName qName)
void	subscribeForOverallStatus()
void	subscribeForRequestStatus()
void	writeEprToFile()

Methods inherited from class java.lang.Object

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

Field Detail

rftRequest

private org.globus.rft.generated.BaseRequestType rftRequest

host

private String host

port

private String port

terminationTime

private int terminationTime

securityType

private String securityType

msgProtectionType

private Integer msgProtectionType

authorization

private Authorization authorization

rftEprFile

private String rftEprFile

delegationEprFile

private String delegationEprFile

rftEndpointReferenceType

private EndpointReferenceType rftEndpointReferenceType

listeners

private Vector listeners

BASE_SERVICE_PATH

private static final String BASE_SERVICE_PATH

See Also:

Constant Field Values

RFT_FACTORY

private static final String RFT_FACTORY

See Also:

Constant Field Values

RFT_SERVICE

private static final String RFT_SERVICE

See Also:

Constant Field Values

endpointType

private String endpointType

rftFactoryUrl

private String rftFactoryUrl

rftServiceUrl

private String rftServiceUrl

rftFactoryPort

private org.globus.rft.generated.ReliableFileTransferFactoryPortType rftFactoryPort

rftPortType

private org.globus.rft.generated.ReliableFileTransferPortType rftPortType

DEFAULT_MSG_PROTECTION

public static final Integer DEFAULT_MSG_PROTECTION

DEFAULT_SECURITY_TYPE

private static final String DEFAULT_SECURITY_TYPE

See Also:

Constant Field Values

DEFAULT_AUTHZ

private static final Authorization DEFAULT_AUTHZ

delegationEpr

protected EndpointReferenceType delegationEpr

clientSecurityDescriptor

private ClientSecurityDescriptor clientSecurityDescriptor

credential

private org.globus.gsi.GlobusCredential credential

consumer

private NotificationConsumerManager consumer

finishedCount

private int finishedCount

failedCount

private int failedCount

transferCount

private int transferCount

status

private String status

overallStatus

private org.globus.rft.generated.OverallStatus overallStatus

requestStatusRP

private org.globus.rft.generated.RequestStatusType requestStatusRP

fault

private BaseFaultType fault

verbose

private boolean verbose

subscribedForRequestStatus

private boolean subscribedForRequestStatus

Constructor Detail

ReliableFileTransferJob

public ReliableFileTransferJob(org.globus.rft.generated.BaseRequestType rftRequest)

ReliableFileTransferJob

public ReliableFileTransferJob()

Method Detail

setRFTRequest

public void setRFTRequest(org.globus.rft.generated.BaseRequestType rftRequest)

getRFTRequest

public org.globus.rft.generated.BaseRequestType getRFTRequest()

setHost

public void setHost(String host)

getHost

public String getHost()

setPort

public void setPort(String port)

getPort

public String getPort()

destroy

public void destroy()
             throws Exception

Throws:

Exception

setTerminationTime

public void setTerminationTime(int terminationTime)

getTerminationTime

public int getTerminationTime()

getStatus

public String getStatus()

setAuthorization

public void setAuthorization(Authorization authorization)

getAuthorization

public Authorization getAuthorization()

setSecurityType

public void setSecurityType(String securityType)

getSecurityType

public String getSecurityType()

setMsgProtectionType

public void setMsgProtectionType(Integer msgProtectionType)

getMsgProtectionType

public Integer getMsgProtectionType()

setRftEprFile

public void setRftEprFile(String rftEprFile)

getRftEprFile

public String getRftEprFile()

setDelegationEprFile

public void setDelegationEprFile(String delegationEprFile)

getDelegationEprFile

public String getDelegationEprFile()

setClientSecurityDescriptor

public void setClientSecurityDescriptor(ClientSecurityDescriptor clientSecurityDescriptor)

getClientSecurityDescriptor

public ClientSecurityDescriptor getClientSecurityDescriptor()

setSecurityOnStub

public void setSecurityOnStub(Stub stub)

setCredential

public void setCredential(org.globus.gsi.GlobusCredential credential)

getCredential

public org.globus.gsi.GlobusCredential getCredential()
                                              throws Exception

Throws:

Exception

setDelegationEpr

public void setDelegationEpr(EndpointReferenceType delegationEpr)

setEndpointType

public void setEndpointType(String endpointType)

getEndpointType

public String getEndpointType()

getDelegationEpr

public EndpointReferenceType getDelegationEpr()
                                                                          throws Exception

Throws:

Exception

setRFTFactoryUrl

public void setRFTFactoryUrl(String rftFactoryUrl)

getRFTFactoryUrl

public String getRFTFactoryUrl()

setRFTServiceUrl

public void setRFTServiceUrl(String rftServiceUrl)

getRFTServiceUrl

public String getRFTServiceUrl()

getRFTFactoryPort

public org.globus.rft.generated.ReliableFileTransferFactoryPortType getRFTFactoryPort()
                                                                               throws Exception

Throws:

Exception

getRFTPort

public org.globus.rft.generated.ReliableFileTransferPortType getRFTPort()
                                                                 throws Exception

Throws:

Exception

create

public EndpointReferenceType create()
                                                                throws Exception

Throws:

Exception

writeEprToFile

public void writeEprToFile()
                    throws Exception

Throws:

Exception

getRftEPR

public EndpointReferenceType getRftEPR()

subscribeForOverallStatus

public void subscribeForOverallStatus()
                               throws Exception

Throws:

Exception

subscribeForRequestStatus

public void subscribeForRequestStatus()
                               throws Exception

Throws:

Exception

subscribe

private void subscribe(QName qName)
                throws Exception

Throws:

Exception

start

public org.globus.rft.generated.StartOutputType start()
                                               throws Exception

Throws:

Exception

getOverallStatus

public org.globus.rft.generated.OverallStatus getOverallStatus()

setOverallStatus

public void setOverallStatus(org.globus.rft.generated.OverallStatus overallStatus)

getFault

public BaseFaultType getFault()

getTransferCount

public int getTransferCount()

setTransferCount

public void setTransferCount(int transferCount)

getFinishedCount

public int getFinishedCount()

setFinishedCount

public void setFinishedCount(int finishedCount)

getFailedCount

public int getFailedCount()

setFailedCount

public void setFailedCount(int failedCount)

setVerbose

public void setVerbose(boolean verbose)
                throws Exception

Throws:

Exception

getVerbose

public boolean getVerbose()

deliver

public void deliver(List topicPath,
                    EndpointReferenceType producer,
                    Object message)

Specified by:

deliver in interface NotifyCallback

getFaultFromRP

public BaseFaultType getFaultFromRP(org.globus.rft.generated.RFTFaultResourcePropertyType faultRP)

addListener

public void addListener(TransferStatusListener listener)

removeListener

public void removeListener(TransferStatusListener listener)