com.ibm.cloud.objectstorage.services.aspera.transfer

Class TransferListener

java.lang.Object

com.ibm.aspera.faspmanager2.ITransferListener

com.ibm.cloud.objectstorage.services.aspera.transfer.TransferListener

public class TransferListener
extends com.ibm.aspera.faspmanager2.ITransferListener

Singleton Listener for the progress of all Aspera transfer. Each status message is parsed for the status and updated in the internal map, using xferId as the key.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	log

Fields inherited from class com.ibm.aspera.faspmanager2.ITransferListener

swigCMemOwn

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransferListener()

Method Summary

Modifier and Type	Method and Description
protected void	finalize() Releasing all resources created by TransferListener before it is being garbage collected.
protected void	fireProgressEvent(String xferid, long bytesTransferred)
static int	getAscpCount() return the current ascp count
static TransferListener	getInstance(String xferId, AsperaTransaction transaction) Returns TransferListener instance and associates an AsperaTransaction with a Transfer ID.
String	getStatus(String xferId)
void	removeAllTransactionSessions(String xferId) Removes all sessions for their specified transaction
void	removeTransaction(String xferid)
void	setStatus(String xferId, String sessionId, String status, long bytes)
void	shutdownThreadPools() Shutdown without interrupting the threads involved
void	transferReporter(String xferId, String msg)

Methods inherited from class com.ibm.aspera.faspmanager2.ITransferListener

delete, getCPtr, swigDirectorDisconnect, swigReleaseOwnership, swigTakeOwnership

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.apache.commons.logging.Log log

Constructor Detail

TransferListener

protected TransferListener()

Method Detail

getInstance

public static TransferListener getInstance(String xferId,
                                           AsperaTransaction transaction)

Returns TransferListener instance and associates an AsperaTransaction with a Transfer ID. On change of transfer status or bytes transferred the TransferLsitener will fire a progress change event to all progress listeners attached to the AsperaTransaction.

Parameters:

xferId -

transaction -

Returns:

transferReporter

public void transferReporter(String xferId,
                             String msg)

Overrides:

transferReporter in class com.ibm.aspera.faspmanager2.ITransferListener

Parameters:

xferId -

msg - Set the status for the xferid

getStatus

public String getStatus(String xferId)

setStatus

public void setStatus(String xferId,
                      String sessionId,
                      String status,
                      long bytes)

getAscpCount

public static int getAscpCount()

return the current ascp count

Returns:

fireProgressEvent

protected void fireProgressEvent(String xferid,
                                 long bytesTransferred)

removeTransaction

public void removeTransaction(String xferid)

removeAllTransactionSessions

public void removeAllTransactionSessions(String xferId)

Removes all sessions for their specified transaction

Parameters:

xferId -

sessionId -

shutdownThreadPools

public void shutdownThreadPools()

Shutdown without interrupting the threads involved

finalize

protected void finalize()

Releasing all resources created by TransferListener before it is being garbage collected.

Overrides:

finalize in class com.ibm.aspera.faspmanager2.ITransferListener