org.trianacode.taskgraph.databus

Interface DataBusInterface

All Known Implementing Classes:

LocalDataBus

public interface DataBusInterface

Interface for defining new databus component for storing and retrieving data that act as an interface between sending and receing data in Triana.

User: scmijt Date: Jul 23, 2010 Time: 3:15:00 PM To change this template use File | Settings | File Templates.

Method Summary

Methods

Modifier and Type	Method and Description
WorkflowDataPacket	addObject(java.lang.Object data, boolean deleteAfterUse) Adds an object to the databus and returns the WorkflowDataPacket that can be used to identify the object.
java.lang.Object	get(WorkflowDataPacket packet) Gets the data out of the store with the provided WorkflowDataPacket
java.lang.String	getProtocol() return the protocol of the URLs minted by this databus
void	putData(WorkflowDataPacket packet, java.lang.Object data) Puts data into the databus
void	remove(WorkflowDataPacket packet) Removes the URL and the data from the store.

Method Detail

getProtocol

java.lang.String getProtocol()

return the protocol of the URLs minted by this databus

Returns:

putData

void putData(WorkflowDataPacket packet,
           java.lang.Object data)

Puts data into the databus

Parameters:

packet -

data -

get

java.lang.Object get(WorkflowDataPacket packet)
                     throws DataNotResolvableException

Gets the data out of the store with the provided WorkflowDataPacket

Parameters:

packet -

Returns:

Throws:

DataNotResolvableException

remove

void remove(WorkflowDataPacket packet)

Removes the URL and the data from the store.

Parameters:

packet -

addObject

WorkflowDataPacket addObject(java.lang.Object data,
                           boolean deleteAfterUse)

Adds an object to the databus and returns the WorkflowDataPacket that can be used to identify the object.

Parameters:

data -

Returns: