File tree Expand file tree Collapse file tree 2 files changed +2
-1
lines changed
metafacture-flowcontrol/src/main
java/org/metafacture/flowcontrol Expand file tree Collapse file tree 2 files changed +2
-1
lines changed Original file line number Diff line number Diff line change 40
40
@ In (Object .class )
41
41
@ Out (Object .class )
42
42
@ Description ("incoming objects are distributed to the added receivers, running in their own threads" )
43
- @ FluxCommand ("threader" )
43
+ @ FluxCommand ("object- threader-tee " )
44
44
public class ObjectThreader <T > extends DefaultTee <ObjectReceiver <T >> implements ObjectPipe <T , ObjectReceiver <T >> {
45
45
46
46
private static final Logger LOG = LoggerFactory .getLogger (ObjectThreader .class );
Original file line number Diff line number Diff line change @@ -20,3 +20,4 @@ batch-reset org.metafacture.flowcontrol.StreamBatchResetter
20
20
reset-object-batch org.metafacture.flowcontrol.ObjectBatchResetter
21
21
defer-stream org.metafacture.flowcontrol.StreamDeferrer
22
22
catch-stream-exception org.metafacture.flowcontrol.StreamExceptionCatcher
23
+ object-threader-tee org.metafacture.flowcontrol.ObjectThreader
You can’t perform that action at this time.
0 commit comments