Add support for onUnscheduled method
Add support for onUnscheduled method1
Add support for onUnscheduled method
Add support for onUnscheduled method
@@ -27,6 +27,7 @@ import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.SeeAlso;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
+import org.apache.nifi.annotation.lifecycle.OnUnscheduled;
import org.apache.nifi.annotation.lifecycle.OnStopped;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.components.RequiredPermission;
@@ -270,6 +271,14 @@ public class ExecuteGroovyScript extends AbstractProcessor {
throw new ProcessException("onStart failed: " + t, t);
}
}
+ @OnUnscheduled
+ public void onUnscheduled(final ProcessContext context) {
+ try {
+ callScriptStatic("onUnscheduled", context);
+ } catch (Throwable t) {
+ throw new ProcessException("onUnscheduled failed: " + t, t);
+ }
+ }
@OnStopped
public void onStopped(final ProcessContext context) {
