org.trianacode.taskgraph.databus

Class LocalDataBus

java.lang.Object

org.trianacode.taskgraph.databus.LocalDataBus

All Implemented Interfaces:

DataBusInterface

public class LocalDataBus
extends java.lang.Object
implements DataBusInterface

Simple local implementation of datstore. Local objects are converted into a local URL which can be used to uniquely identify both the type of the data and the data itself. User: scmijt Date: Jul 23, 2010 Time: 3:15:41 PM To change this template use File | Settings | File Templates.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LOCAL_PROTOCOL

Constructor Summary

Constructors

Constructor and Description
LocalDataBus()

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 url, java.lang.Object data) Puts data into the databus
void	remove(WorkflowDataPacket packet) Removes the URL and the data from the store.

Methods inherited from class java.lang.Object

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

Field Detail

LOCAL_PROTOCOL

public static final java.lang.String LOCAL_PROTOCOL

See Also:

Constant Field Values

Constructor Detail

LocalDataBus

public LocalDataBus()

Method Detail

getProtocol

public java.lang.String getProtocol()

Description copied from interface: DataBusInterface

return the protocol of the URLs minted by this databus

Specified by:

getProtocol in interface DataBusInterface

Returns:

putData

public void putData(WorkflowDataPacket url,
           java.lang.Object data)

Description copied from interface: DataBusInterface

Puts data into the databus

Specified by:

putData in interface DataBusInterface

get

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

Description copied from interface: DataBusInterface

Gets the data out of the store with the provided WorkflowDataPacket

Specified by:

get in interface DataBusInterface

Returns:

Throws:

DataNotResolvableException

remove

public void remove(WorkflowDataPacket packet)

Description copied from interface: DataBusInterface

Removes the URL and the data from the store.

Specified by:

remove in interface DataBusInterface

addObject

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

Description copied from interface: DataBusInterface

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

Specified by:

addObject in interface DataBusInterface

Returns: