in src/main/java/com/amazonaws/kvstranscribestreaming/docker/KVSTranscribeStreamingDocker.java [28:44]
private static String constructEventBody(String[] args) {
final Options options = new Options();
options.addRequiredOption("e", "eventBody", true, "Streaming event body in json format");
final CommandLineParser parser = new DefaultParser();
try {
final CommandLine line = parser.parse(options, args);
final String body = line.getOptionValue('e');
logger.info("{} event body is {}", DOCKER_KEY_PREFIX, body);
return body;
} catch (final Exception e) {
String errorMsg = String.format("Unable to process streaming event. Message: %s", e.getMessage());
logger.error(errorMsg, e);
throw new RuntimeException(errorMsg);
}
}