Package com.levigo.jadice.server.nodes

Class MultiplexerNode

java.lang.Object

com.levigo.jadice.server.internal.NodeInternal

com.levigo.jadice.server.Node

com.levigo.jadice.server.nodes.MultiplexerNode

public class MultiplexerNode
extends Node

This Node multiplexes an input stream bundle into a set of output bundles. Every output bundle will receive an exact copy of the input bundle, i.e. the data is duplicated for each output bundle. The multiplexed streams' contents are not modified in any other way.

Nested Class Summary

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	Description
MultiplexerNode()

Method Summary

Modifier and Type	Method	Description
Node.Cardinality	getOutputCardinality()	Return the output cardinality of this node, i.e.
String	getWorkerClassName()	Return the node's associated com.levigo.jadice.server.core.NodeWorker full qualified class's name.

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

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

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

addSubsidiaryNodes, getJobInternal, getLimit, getLimits, getNodeLimits, setJob, setNodeLimits

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiplexerNode

public MultiplexerNode()

Method Detail

getWorkerClassName

public String getWorkerClassName()

Description copied from class: Node

Return the node's associated com.levigo.jadice.server.core.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.

getOutputCardinality

public Node.Cardinality getOutputCardinality()

Description copied from class: Node

Return the output cardinality of this node, i.e. how many bundles (not streams!) it expects to produce. By default, nodes are "pipe-style", i.e. one input, one output.

Overrides:

getOutputCardinality in class Node

Returns:

output cardinality