Package i5.las2peer.p2p

Class PastryNodeImpl

java.lang.Object

i5.las2peer.api.Configurable

i5.las2peer.p2p.Node

i5.las2peer.p2p.PastryNodeImpl

All Implemented Interfaces:

L2pStorageInterface, NodeStorageInterface, AgentStorage

Direct Known Subclasses:

EthereumNode

public class PastryNodeImpl
extends Node

A FreePastry implementation of a las2peer Node. This class is the actual heart of the p2p based network of interacting nodes an agents in the las2peer setting. The package i5.las2peer.p2p.pastry provides all necessary helper classes for the integration (and encapsulation) of the FreePastry library.

Nested Class Summary

Nested classes/interfaces inherited from class i5.las2peer.p2p.Node

Node.NodeStatus, Node.SendMode

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BOOTSTRAP_PORT

Fields inherited from class i5.las2peer.p2p.Node

DEFAULT_AGENT_CONTEXT_LIFETIME, DEFAULT_CPU_LOAD_TRESHOLD, DEFAULT_INVOCATION_RETRY_COUNT, DEFAULT_NODE_SERVICE_CACHE_LIFETIME, DEFAULT_NODE_SERVICE_CACHE_RESULT_COUNT, DEFAULT_TIDY_UP_TIMER_INTERVAL

Constructor Summary

Constructors

Constructor	Description
PastryNodeImpl(ClassManager classManager, boolean useMonitoringObserver, InetAddress pastryBindAddress, Integer pastryPort, List<String> bootstrap, SharedStorage.STORAGE_MODE storageMode, String storageDir, Long nodeIdSeed)	This is the regular constructor used by the L2pNodeLauncher.
PastryNodeImpl(String bootstrap, SharedStorage.STORAGE_MODE storageMode, String storageDir, Long nodeIdSeed)	This constructor is mainly used by the TestSuite, uses a random system defined port number and sets all parameters for a debugging and testing optimized operation mode.

Method Summary

Modifier and Type	Method	Description
EnvelopeVersion	createEnvelope(EnvelopeVersion previousVersion, Serializable content)	Creates an continuous version instance for the given Envelope.
EnvelopeVersion	createEnvelope(EnvelopeVersion previousVersion, Serializable content, AgentImpl... reader)	Creates an continuous version instance for the given Envelope.
EnvelopeVersion	createEnvelope(EnvelopeVersion previousVersion, Serializable content, Collection<?> readers)	Creates an continous version instance for the given Envelope.
EnvelopeVersion	createEnvelope(String identifier, PublicKey authorPubKey, Serializable content, AgentImpl... reader)	Creates a new version of an Envelope.
EnvelopeVersion	createEnvelope(String identifier, PublicKey authorPubKey, Serializable content, Collection<?> readers)	Creates a new version of an Envelope.
EnvelopeVersion	createUnencryptedEnvelope(EnvelopeVersion previousVersion, Serializable content)	Creates an continous unencrypted version instance for the given Envelope.
EnvelopeVersion	createUnencryptedEnvelope(String identifier, PublicKey authorPubKey, Serializable content)	Creates a new version of an unencrypted Envelope.
EnvelopeVersion	fetchArtifact(long id)	Deprecated. Use fetchEnvelope(String) instead
EnvelopeVersion	fetchArtifact(String identifier)	Deprecated. Use fetchEnvelope(String) instead
EnvelopeVersion	fetchEnvelope(String identifier)	Fetches the latest version for the given identifier from the network.
EnvelopeVersion	fetchEnvelope(String identifier, long timeoutMs)	Fetches the latest version for the given identifier from the network.
void	fetchEnvelopeAsync(String identifier, StorageEnvelopeHandler envelopeHandler, StorageExceptionHandler exceptionHandler)	Fetches the latest version for the given identifier from the network.
byte[]	fetchHashedContent(byte[] hash)
byte[]	fetchHashedContent(byte[] hash, long timeoutMs)
void	fetchHashedContentAsync(byte[] hash, StorageArtifactHandler artifactHandler, StorageExceptionHandler exceptionHandler)
Object[]	findRegisteredAgent(String agentId, int hintOfExpectedCount)	Searches the nodes for registered Versions of the given Agent.
AgentImpl	getAgent(String id)	Gets an agent description from the net.
NodeApplication	getApplication()	provides access to the underlying pastry application mostly for testing purposes
InetAddress	getBindAddress()
long	getLocalMaxStorageSize()
long	getLocalStorageSize()
Serializable	getNodeId()	get the identifier of this node (string representation of the pastry node)
NodeInformation	getNodeInformation(Object nodeId)	Gets information about a distant node.
Object[]	getOtherKnownNodes()	Gets an array with identifiers of other (locally known) nodes in this network.
rice.pastry.PastryNode	getPastryNode()	access to the underlying pastry node
int	getPort()
protected void	launchSub()	start this node
void	registerReceiver(MessageReceiver receiver)	Registers a (local) Agent for usage through this node.
void	registerReceiverToTopic(MessageReceiver receiver, long topic)	register a receiver to a topic
void	removeArtifact(long id, byte[] signature)	Deprecated. Use removeEnvelope(String) instead
void	removeEnvelope(String identifier)	Removes the envelope with the given identifier from the network.
void	sendMessage(Message message, MessageResultListener listener, Node.SendMode mode)	Sends a message, recipient and sender are stated in the message.
void	sendMessage(Message message, Object atNodeId, MessageResultListener listener)	Sends a message to the agent residing at the given node.
protected void	setupRepository()	Add past storage as network repository
void	shutDown()	Stops the node.
void	storeAgent(AgentImpl agent)	Stores a new Agent to the network.
void	storeArtifact(EnvelopeVersion envelope)	Deprecated. Use storeEnvelope(EnvelopeVersion, AgentImpl) instead
void	storeEnvelope(EnvelopeVersion envelope, AgentImpl author)	Stores the given Envelope in the network.
void	storeEnvelope(EnvelopeVersion envelope, AgentImpl author, long timeoutMs)	Stores the given Envelope in the network.
void	storeEnvelopeAsync(EnvelopeVersion envelope, AgentImpl author, StorageStoreResultHandler resultHandler, StorageCollisionHandler collisionHandler, StorageExceptionHandler exceptionHandler)	Stores the given Envelope in the network.
void	storeHashedContent(byte[] content)
void	storeHashedContent(byte[] content, long timeoutMs)
void	storeHashedContentAsync(byte[] content, StorageStoreResultHandler resultHandler, StorageExceptionHandler exceptionHandler)
void	unregisterReceiver(MessageReceiver receiver)	Unregisters a MessageReceiver from this node.
void	unregisterReceiverFromTopic(MessageReceiver receiver, long topic)	unregister a receiver from a topic
void	updateAgent(AgentImpl agent)	Deprecated. Use storeAgent(AgentImpl) instead

Methods inherited from class i5.las2peer.p2p.Node

addObserver, createMediatorForAgent, findRegisteredAgent, findRegisteredAgent, findRegisteredAgent, getAgentContext, getAgentContext, getAgentIdForEmail, getAgentIdForGroupName, getAgentIdForLogin, getBaseClassLoader, getInformationFilename, getLocalAgent, getLocalServiceAgent, getNodeCpuLoad, getNodeFreeRAMLoad, getNodeInformation, getNodeRAMLoad, getNodeRepresentation, getNodeServiceCache, getRegisteredAgents, getRegisteredServices, getServiceAgent, getServiceAliasManager, getStartTime, getStatus, getUserManager, handoverAnswer, hasAgent, hasLocalAgent, hasLocalAgent, hasService, hasTopic, invoke, invoke, invoke, invoke, invokeGlobally, invokeLocally, isBusy, launch, observerNotice, observerNotice, observerNotice, observerNotice, observerNotice, observerNotice, observerNotice, observerNotice, receiveMessage, registerAnswerListener, removeObserver, runTidyUpTimer, sendMessage, sendMessageAndCollectAnswers, sendMessageAndWaitForAnswer, sendMessageAndWaitForAnswer, sendResponse, setCpuLoadThreshold, setInformationFilename, setServiceMonitoring, setStatus, startService, stopService, stopService

Methods inherited from class i5.las2peer.api.Configurable

getProperties, setFieldValues

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_BOOTSTRAP_PORT

public static final int DEFAULT_BOOTSTRAP_PORT

See Also:

• Constant Field Values

Constructor Details

PastryNodeImpl

public PastryNodeImpl(String bootstrap,
 SharedStorage.STORAGE_MODE storageMode,
 String storageDir,
 Long nodeIdSeed)

This constructor is mainly used by the TestSuite, uses a random system defined port number and sets all parameters for a debugging and testing optimized operation mode.

Parameters:

bootstrap - A bootstrap address that should be used, like hostname:port or null to start a new network.

storageMode - A storage mode to be used by this node, see SharedStorage.STORAGE_MODE.

storageDir - A directory to persist data to. Only considered in persistent storage mode. Overwrites SharedStorage configurations, which defines the default value in case of null.

nodeIdSeed - A node id seed to enforce a specific (otherwise random) node id. If null, the node id will be random.

PastryNodeImpl

public PastryNodeImpl(ClassManager classManager,
 boolean useMonitoringObserver,
 InetAddress pastryBindAddress,
 Integer pastryPort,
 List<String> bootstrap,
 SharedStorage.STORAGE_MODE storageMode,
 String storageDir,
 Long nodeIdSeed)

This is the regular constructor used by the L2pNodeLauncher. Its parameters can be set to start a new network or join an existing Pastry ring.

Parameters:

classManager - A class manager that is used by the node.

useMonitoringObserver - If true, the node sends monitoring information to the monitoring service.

pastryBindAddress - An address to bind to, null binds to Internet address

pastryPort - A port number the PastryNode should listen to for network communication. null means use a random system defined port. Use getPort() to retrieve the number.

bootstrap - A list of host addresses that should be used for bootstrap, like hostname:port or null to start a new network.

storageMode - A storage mode to be used by this node, see SharedStorage.STORAGE_MODE.

storageDir - A directory to persist data to. Only considered in persistent storage mode. Overwrites SharedStorage configurations, which defines the default value in case of null.

nodeIdSeed - A node id (random) seed to enforce a specific node id. If null, the node id will be random.

Method Details

getPastryNode

public rice.pastry.PastryNode getPastryNode()

access to the underlying pastry node

Returns:

the pastry node representing this las2peer node

setupRepository

protected void setupRepository()

Add past storage as network repository

launchSub

protected void launchSub()
                  throws NodeException

start this node

Specified by:

launchSub in class Node

Throws:

NodeException - If launching the node fails

shutDown

public void shutDown()

Description copied from class: Node

Stops the node.

Overrides:

shutDown in class Node

registerReceiver

public void registerReceiver(MessageReceiver receiver)
                      throws AgentAlreadyRegisteredException,
AgentException

Description copied from class: Node

Registers a (local) Agent for usage through this node. The Agent has to be unlocked before registration.

Overrides:

registerReceiver in class Node

Parameters:

receiver - A message receiver to register

Throws:

AgentAlreadyRegisteredException - the given agent is already registered to this node

AgentLockedException - the agent is not unlocked

AgentException - any problem with the agent itself (probably on calling AgentImpl.notifyRegistrationTo(i5.las2peer.p2p.Node)

unregisterReceiver

public void unregisterReceiver(MessageReceiver receiver)
                        throws AgentNotRegisteredException,
NodeException

Description copied from class: Node

Unregisters a MessageReceiver from this node.

Overrides:

unregisterReceiver in class Node

Parameters:

receiver - the receiver to unregister

Throws:

AgentNotRegisteredException - The given MessageReceiver is not registered to this node

NodeException - error in underlying layer

registerReceiverToTopic

public void registerReceiverToTopic(MessageReceiver receiver,
 long topic)
                             throws AgentNotRegisteredException

Description copied from class: Node

register a receiver to a topic

Overrides:

registerReceiverToTopic in class Node

Parameters:

receiver - the MessageReceiver

topic - the topic id

Throws:

AgentNotRegisteredException - The given MessageReceiver is not registered to this node

unregisterReceiverFromTopic

public void unregisterReceiverFromTopic(MessageReceiver receiver,
 long topic)
                                 throws NodeException

Description copied from class: Node

unregister a receiver from a topic

Overrides:

unregisterReceiverFromTopic in class Node

Parameters:

receiver - the receiver

topic - the topic id

Throws:

NodeException - If unregistering fails

sendMessage

public void sendMessage(Message message,
 MessageResultListener listener,
 Node.SendMode mode)

Description copied from class: Node

Sends a message, recipient and sender are stated in the message. Depending on the mode, either all nodes running the given agent will be notified of this message, or only a random one. NOTE: Pastry nodes will always use broadcast at the moment!

Specified by:

sendMessage in class Node

Parameters:

message - the message to send

listener - a listener for getting the result separately

mode - is it a broadcast or an any-cast message?

sendMessage

public void sendMessage(Message message,
 Object atNodeId,
 MessageResultListener listener)
                 throws NodeNotFoundException

Description copied from class: Node

Sends a message to the agent residing at the given node.

Specified by:

sendMessage in class Node

Parameters:

message - A message to send

atNodeId - A node id to send from

listener - a listener for getting the result separately

Throws:

NodeNotFoundException - If the node was not found

fetchArtifact

@Deprecated
public EnvelopeVersion fetchArtifact(long id)
                              throws EnvelopeNotFoundException,
EnvelopeException

Deprecated.

Use fetchEnvelope(String) instead

Specified by:

fetchArtifact in class Node

Parameters:

id - An id to identify the envelope

Returns:

the envelope containing the requested artifact

Throws:

EnvelopeNotFoundException - If the envelope was not found

EnvelopeException - If an issue with the envelope occurred

fetchArtifact

@Deprecated
public EnvelopeVersion fetchArtifact(String identifier)
                              throws EnvelopeNotFoundException,
EnvelopeException

Deprecated.

Use fetchEnvelope(String) instead

Specified by:

fetchArtifact in class Node

Parameters:

identifier - An identifier for the envelope

Returns:

the envelope containing the requested artifact

Throws:

EnvelopeNotFoundException - If the envelope was not found

EnvelopeException - If an issue with the envelope occurred

storeArtifact

@Deprecated
public void storeArtifact(EnvelopeVersion envelope)
                   throws EnvelopeException

Deprecated.

Use storeEnvelope(EnvelopeVersion, AgentImpl) instead

Specified by:

storeArtifact in class Node

Parameters:

envelope - An envelope to store

Throws:

EnvelopeAlreadyExistsException - If the envelope already exists

EnvelopeException - If an issue with the envelope occurred

removeArtifact

@Deprecated
public void removeArtifact(long id,
 byte[] signature)
                    throws EnvelopeNotFoundException,
EnvelopeException

Deprecated.

Use removeEnvelope(String) instead

Specified by:

removeArtifact in class Node

Parameters:

id - An identifier for the artifact

signature - A signature to use

Throws:

EnvelopeNotFoundException - If the envelope was not found

EnvelopeException - If an issue with the envelope occurred

findRegisteredAgent

public Object[] findRegisteredAgent(String agentId,
 int hintOfExpectedCount)
                             throws AgentNotRegisteredException

Description copied from class: Node

Searches the nodes for registered Versions of the given Agent. Returns an array of objects identifying the nodes the given agent is registered to.

Specified by:

findRegisteredAgent in class Node

Parameters:

agentId - id of the agent to look for

hintOfExpectedCount - a hint for the expected number of results (e.g. to wait for)

Returns:

array with the IDs of nodes, where the given agent is registered

Throws:

AgentNotRegisteredException - If the agent is not registered at this node

getApplication

public NodeApplication getApplication()

provides access to the underlying pastry application mostly for testing purposes

Returns:

the pastry node application of this pastry node

getAgent

public AgentImpl getAgent(String id)
                   throws AgentNotFoundException,
AgentException

Description copied from class: Node

Gets an agent description from the net. make sure, always to return fresh versions of the requested agent, so that no thread can unlock the private key for another one!

Specified by:

getAgent in interface AgentStorage

Specified by:

getAgent in class Node

Parameters:

id - An agent id

Returns:

the requested agent

Throws:

AgentNotFoundException - If the agent is not found

AgentException - If any other issue with the agent occurs, e. g. XML not readable

storeAgent

public void storeAgent(AgentImpl agent)
                throws AgentException

Description copied from class: Node

Stores a new Agent to the network.

Specified by:

storeAgent in class Node

Parameters:

agent - An agent to store

Throws:

AgentException - If any issue with the agent occurs

updateAgent

@Deprecated
public void updateAgent(AgentImpl agent)
                 throws AgentException

Deprecated.

Use storeAgent(AgentImpl) instead

Description copied from class: Node

Updates an existing agent of the network.

Specified by:

updateAgent in class Node

Parameters:

agent - An agent to update

Throws:

AgentException - If any issue with the agent occurs

getNodeId

public Serializable getNodeId()

get the identifier of this node (string representation of the pastry node)

Specified by:

getNodeId in class Node

Returns:

complete identifier of this pastry node as String

getBindAddress

public InetAddress getBindAddress()

getPort

public int getPort()

getOtherKnownNodes

public Object[] getOtherKnownNodes()

Description copied from class: Node

Gets an array with identifiers of other (locally known) nodes in this network.

Specified by:

getOtherKnownNodes in class Node

Returns:

array with handles of other (known) p2p network nodes

getNodeInformation

public NodeInformation getNodeInformation(Object nodeId)
                                   throws NodeNotFoundException

Description copied from class: Node

Gets information about a distant node.

Specified by:

getNodeInformation in class Node

Parameters:

nodeId - A node id to query

Returns:

information about the node

Throws:

NodeNotFoundException - If the node was not found

getLocalStorageSize

public long getLocalStorageSize()

getLocalMaxStorageSize

public long getLocalMaxStorageSize()

storeEnvelope

public void storeEnvelope(EnvelopeVersion envelope,
 AgentImpl author)
                   throws EnvelopeException

Description copied from interface: NodeStorageInterface

Stores the given Envelope in the network. The content is signed with the key from the given author. If an exception occurs its wrapped as StorageException. With this method collisions are handled by throwing an EnvelopeAlreadyExistsException. This method uses the default timeout defined by the acting node.

Parameters:

envelope - The Envelope to store in the network.

author - The author that is used to sign the content.

Throws:

EnvelopeException - If an issue with the storage occurs.

fetchEnvelope

public EnvelopeVersion fetchEnvelope(String identifier)
                              throws EnvelopeNotFoundException,
EnvelopeException

Description copied from interface: NodeStorageInterface

Fetches the latest version for the given identifier from the network. This method uses the default timeout defined by the acting node.

Parameters:

identifier - An unique identifier for the Envelope.

Returns:

Returns the fetched Envelope from the network.

Throws:

EnvelopeNotFoundException - If no envelope or any part of it was not found in the network.

EnvelopeException - If an issue with the storage occurs.

createEnvelope

public EnvelopeVersion createEnvelope(String identifier,
 PublicKey authorPubKey,
 Serializable content,
 AgentImpl... reader)
                               throws IllegalArgumentException,
SerializationException,
CryptoException

Description copied from interface: L2pStorageInterface

Creates a new version of an Envelope. The Envelope uses by default the start version number.

Parameters:

identifier - An unique identifier for the Envelope.

authorPubKey - The authors public key. Validated on store operation.

content - The actual content that should be stored.

reader - An arbitrary number of Agents, who are allowed to read the content.

Returns:

Returns the Envelope instance.

Throws:

IllegalArgumentException - If the given identifier is null, the version number is below the start version number or too high.

SerializationException - If a problem occurs with object serialization.

CryptoException - If an cryptographic issue occurs.

createEnvelope

public EnvelopeVersion createEnvelope(String identifier,
 PublicKey authorPubKey,
 Serializable content,
 Collection<?> readers)
                               throws IllegalArgumentException,
SerializationException,
CryptoException

Description copied from interface: L2pStorageInterface

Creates a new version of an Envelope. The Envelope uses by default the start version number.

Parameters:

identifier - An unique identifier for the Envelope.

authorPubKey - The authors public key. Validated on store operation.

content - The actual content that should be stored.

readers - An arbitrary number of Agents, who are allowed to read the content.

Returns:

Returns the Envelope instance.

Throws:

IllegalArgumentException - If the given identifier is null, the version number is below the start version number or too high.

SerializationException - If a problem occurs with object serialization.

CryptoException - If an cryptographic issue occurs.

createEnvelope

public EnvelopeVersion createEnvelope(EnvelopeVersion previousVersion,
 Serializable content)
                               throws IllegalArgumentException,
SerializationException,
CryptoException

Description copied from interface: L2pStorageInterface

Creates an continuous version instance for the given Envelope. This method copies the reader list from the previous Envelope instance.

Parameters:

previousVersion - The previous version of the Envelope that should be updated.

content - The updated content that should be stored.

Returns:

Returns the Envelope instance.

Throws:

IllegalArgumentException - If the given identifier is null, the version number is below the start version number or too high.

SerializationException - If a problem occurs with object serialization.

CryptoException - If an cryptographic issue occurs.

createEnvelope

public EnvelopeVersion createEnvelope(EnvelopeVersion previousVersion,
 Serializable content,
 AgentImpl... reader)
                               throws IllegalArgumentException,
SerializationException,
CryptoException

Description copied from interface: L2pStorageInterface

Creates an continuous version instance for the given Envelope.

Parameters:

previousVersion - The previous version of the Envelope that should be updated.

content - The updated content that should be stored.

reader - An arbitrary number of Agents, who are allowed to read the content.

Returns:

Returns the Envelope instance.

Throws:

IllegalArgumentException - If the given identifier is null, the version number is below the start version number or too high.

SerializationException - If a problem occurs with object serialization.

CryptoException - If an cryptographic issue occurs.

createEnvelope

public EnvelopeVersion createEnvelope(EnvelopeVersion previousVersion,
 Serializable content,
 Collection<?> readers)
                               throws IllegalArgumentException,
SerializationException,
CryptoException

Description copied from interface: L2pStorageInterface

Creates an continous version instance for the given Envelope.

Parameters:

previousVersion - The previous version of the Envelope that should be updated.

content - The updated content that should be stored.

readers - An arbitrary number of Agents, who are allowed to read the content.

Returns:

Returns the Envelope instance.

Throws:

IllegalArgumentException - If the given identifier is null, the version number is below the start version number or too high.

SerializationException - If a problem occurs with object serialization.

CryptoException - If an cryptographic issue occurs.

createUnencryptedEnvelope

public EnvelopeVersion createUnencryptedEnvelope(String identifier,
 PublicKey authorPubKey,
 Serializable content)
                                          throws IllegalArgumentException,
SerializationException,
CryptoException

Description copied from interface: L2pStorageInterface

Creates a new version of an unencrypted Envelope. The Envelope uses by default the start version number.

Parameters:

identifier - An unique identifier for the Envelope.

authorPubKey - The authors public key. Validated on store operation.

content - The updated content that should be stored.

Returns:

Returns the Envelope instance.

Throws:

IllegalArgumentException - If the given identifier is null, the version number is below the start version number or too high.

SerializationException - If a problem occurs with object serialization.

CryptoException - If an cryptographic issue occurs.

createUnencryptedEnvelope

public EnvelopeVersion createUnencryptedEnvelope(EnvelopeVersion previousVersion,
 Serializable content)
                                          throws IllegalArgumentException,
SerializationException,
CryptoException

Description copied from interface: L2pStorageInterface

Creates an continous unencrypted version instance for the given Envelope.

Parameters:

previousVersion - The previous version of the Envelope that should be updated.

content - The updated content that should be stored.

Returns:

Returns the Envelope instance.

Throws:

IllegalArgumentException - If the given identifier is null, the version number is below the start version number or too high.

SerializationException - If a problem occurs with object serialization.

CryptoException - If an cryptographic issue occurs.

storeEnvelope

public void storeEnvelope(EnvelopeVersion envelope,
 AgentImpl author,
 long timeoutMs)
                   throws EnvelopeException

Description copied from interface: L2pStorageInterface

Stores the given Envelope in the network. The content is signed with the key from the given author. If an exception occurs it's wrapped as StorageException. With this method collisions are handled by throwing an EnvelopeAlreadyExistsException.

Parameters:

envelope - The Envelope to store in the network.

author - The author that is used to sign the content.

timeoutMs - A timeout after that an EnvelopeException is thrown.

Throws:

EnvelopeAlreadyExistsException - If an Envelope with the given identifier and version is already known in the network.

EnvelopeException - If an issue with the storage occurs.

storeEnvelopeAsync

public void storeEnvelopeAsync(EnvelopeVersion envelope,
 AgentImpl author,
 StorageStoreResultHandler resultHandler,
 StorageCollisionHandler collisionHandler,
 StorageExceptionHandler exceptionHandler)

Description copied from interface: L2pStorageInterface

Stores the given Envelope in the network. The content is signed with the key from the given author. If an exception occurs the operation is canceled and the exception handler is called. Same for collisions. If the operations is completed the result handler is called.

Parameters:

envelope - The Envelope to store in the network.

author - The author that is used to sign the content.

resultHandler - A result handler that is called, if the operation terminates.

collisionHandler - A collision handler that is called, if an Envelope with the given identifier and version already exists.

exceptionHandler - An exception handler that is called, if an exception occurs.

fetchEnvelope

public EnvelopeVersion fetchEnvelope(String identifier,
 long timeoutMs)
                              throws EnvelopeNotFoundException,
EnvelopeException

Description copied from interface: L2pStorageInterface

Fetches the latest version for the given identifier from the network.

Parameters:

identifier - An unique identifier for the Envelope.

timeoutMs - A timeout after that an EnvelopeException is thrown.

Returns:

Returns the fetched Envelope from the network.

Throws:

EnvelopeNotFoundException - If no envelope or any part of it was not found in the network.

EnvelopeException - If an issue with the storage occurs.

fetchEnvelopeAsync

public void fetchEnvelopeAsync(String identifier,
 StorageEnvelopeHandler envelopeHandler,
 StorageExceptionHandler exceptionHandler)

Description copied from interface: L2pStorageInterface

Fetches the latest version for the given identifier from the network.

Parameters:

identifier - An unique identifier for the Envelope.

envelopeHandler - A result handler that is called, if the operation terminates.

exceptionHandler - An exception handler that is called, if an exception occurs.

removeEnvelope

public void removeEnvelope(String identifier)
                    throws EnvelopeNotFoundException,
EnvelopeException

Description copied from interface: L2pStorageInterface

Removes the envelope with the given identifier from the network.

Parameters:

identifier - An unique identifier for the Envelope.

Throws:

EnvelopeNotFoundException - If no envelope or any part of it was not found in the network.

EnvelopeException - If an issue with the storage occurs.

storeHashedContentAsync

public void storeHashedContentAsync(byte[] content,
 StorageStoreResultHandler resultHandler,
 StorageExceptionHandler exceptionHandler)

storeHashedContent

public void storeHashedContent(byte[] content)
                        throws EnvelopeException

Throws:

EnvelopeException

storeHashedContent

public void storeHashedContent(byte[] content,
 long timeoutMs)
                        throws EnvelopeException

Throws:

EnvelopeException

fetchHashedContentAsync

public void fetchHashedContentAsync(byte[] hash,
 StorageArtifactHandler artifactHandler,
 StorageExceptionHandler exceptionHandler)

fetchHashedContent

public byte[] fetchHashedContent(byte[] hash)
                          throws EnvelopeException

Throws:

EnvelopeException

fetchHashedContent

public byte[] fetchHashedContent(byte[] hash,
 long timeoutMs)
                          throws EnvelopeException

Throws:

EnvelopeException