org.trianacode.taskgraph.databus.packet

Class WorkflowDataPacket

java.lang.Object

org.trianacode.taskgraph.databus.packet.WorkflowDataPacket

All Implemented Interfaces:

java.io.Serializable

public class WorkflowDataPacket
extends java.lang.Object
implements java.io.Serializable

Simple wrapper for passing URLs between workflow units that allowfor adding extra metadata to be included along with the transfer. For now, we just provide a hint to whether that data should be deleted after use for garbage colleciton.

All initial planned DatabusInterfaces should implement a garbage colleciton mechanims. Initial ones are:

1. A local store (using a hashtable but exposed using REST also) 2. HTTP using the same mechanism - HTTP needs a cleanup method http://server/triana/cleanup?dataid say 3. Attic, which should support the deletion of data from the distributed data store.

We'll use serialisation of this object for now but JSON later.

User: Ian Taylor Date: Jul 24, 2010 Time: 12:42:20 PM To change this template use File | Settings | File Templates.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WorkflowDataPacket(java.net.URI dataLocation, boolean deleteAfterUse)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.net.URI	getDataLocation()
java.lang.String	getProtocol()
int	hashCode()
boolean	isDeleteAfterUse()
void	setDeleteAfterUse(boolean deleteAfterUse)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkflowDataPacket

public WorkflowDataPacket(java.net.URI dataLocation,
                  boolean deleteAfterUse)

Method Detail

getProtocol

public java.lang.String getProtocol()

getDataLocation

public java.net.URI getDataLocation()

isDeleteAfterUse

public boolean isDeleteAfterUse()

setDeleteAfterUse

public void setDeleteAfterUse(boolean deleteAfterUse)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object