src/main/java/org/embulk/output/kintone/KintonePageOutput.java in embulk-output-kintone-0.3.2 vs src/main/java/org/embulk/output/kintone/KintonePageOutput.java in embulk-output-kintone-0.3.3
- old
+ new
@@ -117,10 +117,14 @@
}
private void execute(Consumer<KintoneClient> operation)
{
connect(task);
- operation.accept(this.client);
+ if (this.client != null) {
+ operation.accept(this.client);
+ } else {
+ throw new RuntimeException("Failed to connect to kintone.");
+ }
}
private void insertPage(final Page page)
{
execute(client -> {