in src/main/java/com/amazonaws/services/dynamodbv2/streams/connectors/CommandLineInterface.java [60:77]
public static void main(String[] args) {
try {
final Optional<Worker> workerOption = mainUnsafe(args);
if (!workerOption.isPresent()) {
return;
}
System.out.println("Starting replication now, check logs for more details.");
workerOption.get().run();
} catch (ParameterException e) {
log.error(e);
JCommander.getConsole().println(e.toString());
System.exit(StatusCodes.EINVAL);
} catch (Exception e) {
log.fatal(e);
JCommander.getConsole().println(e.toString());
System.exit(StatusCodes.EINVAL);
}
}