class StreamsShellBolt extends AbstractProcessorBolt {

    public StreamsShellBolt(String command, int processTimeoutInMs) {
        if(command == null || command.isEmpty())
            throw new IllegalArgumentException("process command can not be empty");
        this.command = command;
        this.processTimeoutInMs = processTimeoutInMs;
    }

    public  StreamsShellBolt(String command, int processTimeoutInMs);

}