com.levigo.jadice.server.notification

Class NotificationNode

java.lang.Object

com.levigo.jadice.server.internal.NodeInternal

com.levigo.jadice.server.Node

com.levigo.jadice.server.notification.NotificationNode

public class NotificationNode
extends Node

A Node that notifies the client about every Stream that passes through it. Register NotificationNode.NotificationListeners that care about these events.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	NotificationNode.NotificationListener The listener that's notified when a Stream passes through this node.

Nested classes/interfaces inherited from class com.levigo.jadice.server.Node

Node.Cardinality

Field Summary

Fields inherited from class com.levigo.jadice.server.internal.NodeInternal

limits, subsidiaryNodes

Constructor Summary

Constructors

Constructor and Description
NotificationNode()

Method Summary

Methods

Modifier and Type	Method and Description
void	addNotificationResultListener(NotificationNode.NotificationListener listener) Adds a listener to be informed about a Stream passing through this node.
String	getWorkerClassName() Return the node's associated NodeWorker full qualified class's name.
protected void	initialize(CommunicationSide side)
void	removeNotificationResultListener(NotificationNode.NotificationListener listener) Removes a NotificationNode.NotificationListener for the events.

Methods inherited from class com.levigo.jadice.server.Node

addTransportReceiver, appendSuccessor, apply, equals, getInputCardinality, getJob, getOutputCardinality, getPredecessors, getSubsidiaryNodes, getSuccessors, getTransportSender, getUUID, hashCode, prependPredecessor, remove, validateConfiguration

Methods inherited from class com.levigo.jadice.server.internal.NodeInternal

addSubsidiaryNodes, getJobInternal, getLimit, getLimits, getNodeLimits, setNodeLimits

Methods inherited from class java.lang.Object

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

Constructor Detail

NotificationNode

public NotificationNode()

Method Detail

initialize

protected void initialize(CommunicationSide side)

Overrides:

initialize in class Node

addNotificationResultListener

public void addNotificationResultListener(NotificationNode.NotificationListener listener)

Adds a listener to be informed about a Stream passing through this node.

Parameters:

listener - The listener to add

removeNotificationResultListener

public void removeNotificationResultListener(NotificationNode.NotificationListener listener)

Removes a NotificationNode.NotificationListener for the events.

Parameters:

listener - The listener to remove

getWorkerClassName

public String getWorkerClassName()

Description copied from class: Node

Return the node's associated NodeWorker full qualified class's name. By default, the worker class name is

• The same as the node name with the trailing "Node" replaced by "Worker" if the node name ends in "Node"
• The node class name with an appended "Worker" otherwise.

The package name of the worker class is the name of the Node's package with an appended ".worker".

This behavior can be overridden in concrete subclasses.

Overrides:

getWorkerClassName in class Node

Returns:

the full qualified class name of the worker of this node.