Commit 4a1df7d8 authored by Sören Henning's avatar Sören Henning

first draft of RecordDistributor

parent 5b309c16
package anomalydetection.kieker;
import java.util.HashMap;
import java.util.Map;
import java.util.Map.Entry;
import teetime.framework.AbstractConsumerStage;
import teetime.framework.OutputPort;
public class RecordDistributor extends AbstractConsumerStage<MonitoringRecord> {
private final Map<RecordFilter, OutputPort<MonitoringRecord>> outputPorts = new HashMap<>();
protected void execute(final MonitoringRecord record) {
for (Entry<RecordFilter, OutputPort<MonitoringRecord>> entry : outputPorts.entrySet()) {
if (entry.getKey().test(record)) {
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment