Skip to content

Commit a432554

Browse files
committed
Rename flux command to convention (starting with a verb)
1 parent a518580 commit a432554

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/ObjectThreader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@
4040
@In(Object.class)
4141
@Out(Object.class)
4242
@Description("incoming objects are distributed to the added receivers, running in their own threads")
43-
@FluxCommand("object-threader-tee")
43+
@FluxCommand("thread-object-tee")
4444
public class ObjectThreader<T> extends DefaultTee<ObjectReceiver<T>> implements ObjectPipe<T, ObjectReceiver<T>> {
4545

4646
private static final Logger LOG = LoggerFactory.getLogger(ObjectThreader.class);

metafacture-flowcontrol/src/main/resources/flux-commands.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,4 +20,4 @@ batch-reset org.metafacture.flowcontrol.StreamBatchResetter
2020
reset-object-batch org.metafacture.flowcontrol.ObjectBatchResetter
2121
defer-stream org.metafacture.flowcontrol.StreamDeferrer
2222
catch-stream-exception org.metafacture.flowcontrol.StreamExceptionCatcher
23-
object-threader-tee org.metafacture.flowcontrol.ObjectThreader
23+
thread-object-tee org.metafacture.flowcontrol.ObjectThreader

0 commit comments

Comments
 (0)