Package com.helix.cli

Class StreamCommand

java.lang.Object

com.helix.cli.StreamCommand

All Implemented Interfaces:

CliCommand, Callable<Integer>

public class StreamCommand
extends Object
implements CliCommand

Picocli subcommand for streaming rule execution via Apache Kafka or LMAX Disruptor. Runs as a daemon with graceful SIGINT shutdown handling and runtime stats reporting.

Constructor Summary

Constructors

Constructor	Description
StreamCommand()
StreamCommand(StreamBridge bridge)

Method Summary

Modifier and Type	Method	Description
Integer	call()	Executes the command logic.
void	setInjectedBridge(StreamBridge bridge)
void	triggerShutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamCommand

public StreamCommand()

StreamCommand

public StreamCommand(StreamBridge bridge)

Method Details

setInjectedBridge

public void setInjectedBridge(StreamBridge bridge)

triggerShutdown

public void triggerShutdown()

call

public Integer call()

Description copied from interface: CliCommand

Executes the command logic.

Specified by:

call in interface Callable<Integer>

Specified by:

call in interface CliCommand

Returns:

exit status code (0 for success, 1 for compilation error, 2 for execution error)