Skip to content
This repository was archived by the owner on May 16, 2025. It is now read-only.

Commit 4453635

Browse files
authored
Merge pull request #370 from metafacture/add-signature-and-description
Update Metafix.java
2 parents 81a88bc + ec7f9ec commit 4453635

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

metafix/src/main/java/org/metafacture/metafix/Metafix.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,10 +18,14 @@
1818

1919
package org.metafacture.metafix;
2020

21+
import org.metafacture.framework.FluxCommand;
2122
import org.metafacture.framework.MetafactureException;
2223
import org.metafacture.framework.StandardEventNames;
2324
import org.metafacture.framework.StreamPipe;
2425
import org.metafacture.framework.StreamReceiver;
26+
import org.metafacture.framework.annotations.Description;
27+
import org.metafacture.framework.annotations.In;
28+
import org.metafacture.framework.annotations.Out;
2529
import org.metafacture.framework.helpers.DefaultStreamReceiver;
2630
import org.metafacture.mangling.StreamFlattener;
2731
import org.metafacture.metafix.fix.Expression;
@@ -57,6 +61,10 @@
5761
* @author Christoph Böhme (Metamorph)
5862
* @author Fabian Steeg (Metafix)
5963
*/
64+
@Description("Applies a fix transformation to the event stream, given as the path to a fix file or the fixes themselves.") // checkstyle-disable-line ClassDataAbstractionCoupling|ClassFanOutComplexity
65+
@In(StreamReceiver.class)
66+
@Out(StreamReceiver.class)
67+
@FluxCommand("fix")
6068
public class Metafix implements StreamPipe<StreamReceiver>, Maps { // checkstyle-disable-line ClassDataAbstractionCoupling
6169
public static final String ARRAY_MARKER = "[]";
6270
public static final String FIX_EXTENSION = ".fix";

0 commit comments

Comments
 (0)