com.exalead.mercury.mami.connect.v10

Class MultithreadedDispatchBranch

java.lang.Object

com.exalead.mercury.mami.connect.v10.BranchAction

com.exalead.mercury.mami.connect.v10.PipelineBranch

com.exalead.mercury.mami.connect.v10.MultithreadedDispatchBranch

All Implemented Interfaces:

com.exalead.util.Checkable, java.io.Serializable

public class MultithreadedDispatchBranch
extends PipelineBranch
implements com.exalead.util.Checkable, java.io.Serializable

Replicates a branch multiple times and connects a dispatch to the input and a union to the output

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_NB_THREADS
int	nbThreads

Fields inherited from class com.exalead.mercury.mami.connect.v10.PipelineBranch

autolink, branchAction, DEFAULT_AUTOLINK, input, output, pipelineLink

Fields inherited from class com.exalead.mercury.mami.connect.v10.BranchAction

name

Constructor Summary

Constructors

Constructor and Description
MultithreadedDispatchBranch()
MultithreadedDispatchBranch(MultithreadedDispatchBranch o) Copy constructor

Method Summary

Modifier and Type	Method and Description
void	check(boolean deep, java.lang.String errorContext) Checks this MultithreadedDispatchBranch.
static MultithreadedDispatchBranch	fromString(java.lang.String s) String representation of this MultithreadedDispatchBranch.
int	getNbThreads() Number of replications of this branch
MultithreadedDispatchBranch	makeCopy() Creates and returns a deep copy of this MultithreadedDispatchBranch.
static MultithreadedDispatchBranch	readFrom(java.io.InputStream is) Read this MultithreadedDispatchBranch from an XML fragment.
void	setNbThreads(int nbThreads) Number of replications of this branch
java.lang.String	toString() String representation of this MultithreadedDispatchBranch.
MultithreadedDispatchBranch	withAutolink(boolean autolink)
MultithreadedDispatchBranch	withAutolink(java.lang.Boolean autolink)
MultithreadedDispatchBranch	withBranchAction(BranchAction... __values) Actions in the branch
MultithreadedDispatchBranch	withBranchAction(java.util.Collection<BranchAction> __values)
MultithreadedDispatchBranch	withInput(java.lang.String input)
MultithreadedDispatchBranch	withName(java.lang.String name)
MultithreadedDispatchBranch	withNbThreads(int nbThreads)
MultithreadedDispatchBranch	withNbThreads(java.lang.Integer nbThreads)
MultithreadedDispatchBranch	withOutput(java.lang.String output)
MultithreadedDispatchBranch	withPipelineLink(java.util.Collection<PipelineLink> __values)
MultithreadedDispatchBranch	withPipelineLink(PipelineLink... __values) Links between actions
void	writeTo(java.io.OutputStream os) Write this MultithreadedDispatchBranch as an XML fragment

Methods inherited from class com.exalead.mercury.mami.connect.v10.PipelineBranch

getBranchAction, getBranchActionAsMap, getBranchActionByName, getInput, getOutput, getPipelineLink, isAutolink, removeBranchActionByName, setAutolink, setInput, setOutput

Methods inherited from class com.exalead.mercury.mami.connect.v10.BranchAction

getName, setName

Methods inherited from class java.lang.Object

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

Field Detail

nbThreads

public int nbThreads

DEFAULT_NB_THREADS

public static final int DEFAULT_NB_THREADS

See Also:

Constant Field Values

Constructor Detail

MultithreadedDispatchBranch

public MultithreadedDispatchBranch()

MultithreadedDispatchBranch

public MultithreadedDispatchBranch(MultithreadedDispatchBranch o)

Copy constructor

Method Detail

withBranchAction

public MultithreadedDispatchBranch withBranchAction(BranchAction... __values)

Actions in the branch

Overrides:

withBranchAction in class PipelineBranch

withBranchAction

public MultithreadedDispatchBranch withBranchAction(java.util.Collection<BranchAction> __values)

Overrides:

withBranchAction in class PipelineBranch

withPipelineLink

public MultithreadedDispatchBranch withPipelineLink(PipelineLink... __values)

Links between actions

Overrides:

withPipelineLink in class PipelineBranch

withPipelineLink

public MultithreadedDispatchBranch withPipelineLink(java.util.Collection<PipelineLink> __values)

Overrides:

withPipelineLink in class PipelineBranch

withInput

public MultithreadedDispatchBranch withInput(java.lang.String input)

Overrides:

withInput in class PipelineBranch

withOutput

public MultithreadedDispatchBranch withOutput(java.lang.String output)

Overrides:

withOutput in class PipelineBranch

withAutolink

public MultithreadedDispatchBranch withAutolink(boolean autolink)

Overrides:

withAutolink in class PipelineBranch

withAutolink

public MultithreadedDispatchBranch withAutolink(java.lang.Boolean autolink)

Overrides:

withAutolink in class PipelineBranch

withName

public MultithreadedDispatchBranch withName(java.lang.String name)

Overrides:

withName in class PipelineBranch

setNbThreads

public void setNbThreads(int nbThreads)

Number of replications of this branch

getNbThreads

public int getNbThreads()

Number of replications of this branch

withNbThreads

public MultithreadedDispatchBranch withNbThreads(int nbThreads)

withNbThreads

public MultithreadedDispatchBranch withNbThreads(java.lang.Integer nbThreads)

makeCopy

public MultithreadedDispatchBranch makeCopy()

Creates and returns a deep copy of this MultithreadedDispatchBranch.

Overrides:

makeCopy in class PipelineBranch

readFrom

public static MultithreadedDispatchBranch readFrom(java.io.InputStream is)
                                            throws javax.xml.bind.JAXBException

Read this MultithreadedDispatchBranch from an XML fragment.

Throws:

javax.xml.bind.JAXBException

writeTo

public void writeTo(java.io.OutputStream os)
             throws javax.xml.bind.JAXBException,
                    java.io.IOException

Write this MultithreadedDispatchBranch as an XML fragment

Overrides:

writeTo in class PipelineBranch

Throws:

javax.xml.bind.JAXBException

java.io.IOException

fromString

public static MultithreadedDispatchBranch fromString(java.lang.String s)
                                              throws javax.xml.bind.JAXBException,
                                                     java.io.UnsupportedEncodingException

String representation of this MultithreadedDispatchBranch.

Throws:

javax.xml.bind.JAXBException

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

String representation of this MultithreadedDispatchBranch.

Overrides:

toString in class PipelineBranch

check

public void check(boolean deep,
                  java.lang.String errorContext)
           throws com.exalead.util.TypedException

Checks this MultithreadedDispatchBranch.

Specified by:

check in interface com.exalead.util.Checkable

Overrides:

check in class PipelineBranch

Throws:

com.exalead.util.TypedException