Class MultiplexerAccumulator

java.lang.Object

com.scivicslab.actoriac.accumulator.MultiplexerAccumulator

All Implemented Interfaces:

com.scivicslab.pojoactor.core.accumulator.Accumulator

public class MultiplexerAccumulator
extends Object
implements com.scivicslab.pojoactor.core.accumulator.Accumulator

Multiplexer accumulator that forwards output to multiple downstream accumulators.

This accumulator receives all output from Node/NodeGroup actors and forwards it to configured downstream accumulators (console, file, database). This ensures that all output destinations receive identical content.

Architecture

Node/NodeGroup Actors
       │
       │ all output (cowsay, stdout, stderr)
       ▼
MultiplexerAccumulator
       │
       ├─→ ConsoleAccumulator → System.out
       ├─→ FileAccumulator → text file
       └─→ DatabaseAccumulator → H2 database

Usage

MultiplexerAccumulator multiplexer = new MultiplexerAccumulator();
multiplexer.addTarget(new ConsoleAccumulator());
multiplexer.addTarget(new FileAccumulator(logFile));
multiplexer.addTarget(new DatabaseAccumulator(logStore, sessionId));

// All output goes through the multiplexer
multiplexer.add("node-1", "stdout", "command output...");
multiplexer.add("workflow", "cowsay", cowsayOutput);

Since:

2.12.0

Author:

devteam@scivicslab.com

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	count
private final List<com.scivicslab.pojoactor.core.accumulator.Accumulator>	targets

Constructor Summary

Constructors

Constructor	Description
MultiplexerAccumulator()	Constructs an empty MultiplexerAccumulator.

Method Summary

Modifier and Type	Method	Description
void	add(String source, String type, String data)
void	addTarget(com.scivicslab.pojoactor.core.accumulator.Accumulator target)	Adds a downstream accumulator target.
void	clear()
int	getCount()
String	getSummary()
int	getTargetCount()	Returns the number of downstream targets.
boolean	removeTarget(com.scivicslab.pojoactor.core.accumulator.Accumulator target)	Removes a downstream accumulator target.

Methods inherited from class Object

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

Field Details

targets

private final List<com.scivicslab.pojoactor.core.accumulator.Accumulator> targets

count

private final AtomicInteger count

Constructor Details

MultiplexerAccumulator

public MultiplexerAccumulator()

Constructs an empty MultiplexerAccumulator. Use addTarget(Accumulator) to add downstream accumulators.

Method Details

addTarget

public void addTarget(com.scivicslab.pojoactor.core.accumulator.Accumulator target)

Adds a downstream accumulator target.

All data added to this multiplexer will be forwarded to this target.

Parameters:

target - the downstream accumulator to add

removeTarget

public boolean removeTarget(com.scivicslab.pojoactor.core.accumulator.Accumulator target)

Removes a downstream accumulator target.

Parameters:

target - the downstream accumulator to remove

Returns:

true if the target was removed, false if it was not found

getTargetCount

public int getTargetCount()

Returns the number of downstream targets.

Returns:

the number of targets

add

public void add(String source,
 String type,
 String data)

Specified by:

add in interface com.scivicslab.pojoactor.core.accumulator.Accumulator

getSummary

public String getSummary()

Specified by:

getSummary in interface com.scivicslab.pojoactor.core.accumulator.Accumulator

getCount

public int getCount()

Specified by:

getCount in interface com.scivicslab.pojoactor.core.accumulator.Accumulator

clear

public void clear()

Specified by:

clear in interface com.scivicslab.pojoactor.core.accumulator.Accumulator