Fix reconnecting for Error Store

Resolves siddhi-io#1754
dilini-muthumala · Nov 4, 2021 · 801536d · 801536d
1 parent 5626bc5
commit 801536d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/sink/Sink.java b/modules/siddhi-core/src/main/java/io/siddhi/core/stream/output/sink/Sink.java
@@ -435,6 +435,7 @@ public void onError(Object payload, DynamicOptions dynamicOptions, Exception e)
                     }
                     break;
                 case STORE:
+                    connectWithRetry();
                     ErroneousEvent erroneousEvent = new ErroneousEvent(dynamicOptions.getEvent(), e, e.getMessage());
                     erroneousEvent.setOriginalPayload(payload);
                     ErrorStoreHelper.storeErroneousEvent(siddhiAppContext.getSiddhiContext().getErrorStore(),