com.exalead.mercury.mami.connect.v10

Class UnionProcess

java.lang.Object

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

com.exalead.mercury.mami.connect.v10.ProcessAction

com.exalead.mercury.mami.connect.v10.UnionProcess

All Implemented Interfaces:

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

public class UnionProcess
extends ProcessAction
implements com.exalead.util.Checkable, java.io.Serializable

Creates a UnionProcessor

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DEFAULT_ORDERING_BY_MARKER
boolean	orderingByMarker

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

name

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	check(boolean deep, java.lang.String errorContext) Checks this UnionProcess.
static UnionProcess	fromString(java.lang.String s) String representation of this UnionProcess.
boolean	isOrderingByMarker() This behavior enables the restoration of sessions when a stream has been split into multiple streams which are joined by this processor.
UnionProcess	makeCopy() Creates and returns a deep copy of this UnionProcess.
static UnionProcess	readFrom(java.io.InputStream is) Read this UnionProcess from an XML fragment.
void	setOrderingByMarker(boolean orderingByMarker) This behavior enables the restoration of sessions when a stream has been split into multiple streams which are joined by this processor.
java.lang.String	toString() String representation of this UnionProcess.
UnionProcess	withName(java.lang.String name)
UnionProcess	withOrderingByMarker(boolean orderingByMarker)
UnionProcess	withOrderingByMarker(java.lang.Boolean orderingByMarker)
void	writeTo(java.io.OutputStream os) Write this UnionProcess as an XML fragment

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

orderingByMarker

public boolean orderingByMarker

DEFAULT_ORDERING_BY_MARKER

public static final boolean DEFAULT_ORDERING_BY_MARKER

See Also:

Constant Field Values

Constructor Detail

UnionProcess

public UnionProcess()

UnionProcess

public UnionProcess(UnionProcess o)

Copy constructor

Method Detail

withName

public UnionProcess withName(java.lang.String name)

Overrides:

withName in class ProcessAction

setOrderingByMarker

public void setOrderingByMarker(boolean orderingByMarker)

This behavior enables the restoration of sessions when a stream has been split into
multiple streams which are joined by this processor. Even if some split streams
process faster, the elements from the previous session will all be sent before
beginning to send the next one.

isOrderingByMarker

public boolean isOrderingByMarker()

This behavior enables the restoration of sessions when a stream has been split into
multiple streams which are joined by this processor. Even if some split streams
process faster, the elements from the previous session will all be sent before
beginning to send the next one.

withOrderingByMarker

public UnionProcess withOrderingByMarker(boolean orderingByMarker)

withOrderingByMarker

public UnionProcess withOrderingByMarker(java.lang.Boolean orderingByMarker)

makeCopy

public UnionProcess makeCopy()

Creates and returns a deep copy of this UnionProcess.

Overrides:

makeCopy in class ProcessAction

readFrom

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

Read this UnionProcess 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 UnionProcess as an XML fragment

Overrides:

writeTo in class ProcessAction

Throws:

javax.xml.bind.JAXBException

java.io.IOException

fromString

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

String representation of this UnionProcess.

Throws:

javax.xml.bind.JAXBException

java.io.UnsupportedEncodingException

toString

public java.lang.String toString()

String representation of this UnionProcess.

Overrides:

toString in class ProcessAction

check

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

Checks this UnionProcess.

Specified by:

check in interface com.exalead.util.Checkable

Overrides:

check in class ProcessAction

Throws:

com.exalead.util.TypedException