From 020f9d0596c779bad831c9e412545a3bb303f3ff Mon Sep 17 00:00:00 2001 From: m-hogue Date: Fri, 10 Nov 2017 09:16:11 -0500 Subject: [PATCH] NIFI-4584: Added @EventDriven to InvokeGRPC Signed-off-by: Pierre Villard This closes #2265. --- .../main/java/org/apache/nifi/processors/grpc/InvokeGRPC.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/InvokeGRPC.java b/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/InvokeGRPC.java index 6765928f9e..7d31f6c884 100644 --- a/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/InvokeGRPC.java +++ b/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/InvokeGRPC.java @@ -19,6 +19,7 @@ package org.apache.nifi.processors.grpc; import com.google.protobuf.ByteString; import org.apache.commons.lang3.StringUtils; +import org.apache.nifi.annotation.behavior.EventDriven; import org.apache.nifi.annotation.behavior.InputRequirement; import org.apache.nifi.annotation.behavior.SupportsBatching; import org.apache.nifi.annotation.behavior.WritesAttribute; @@ -63,6 +64,7 @@ import io.grpc.netty.GrpcSslContexts; import io.grpc.netty.NettyChannelBuilder; import io.netty.handler.ssl.SslContextBuilder; +@EventDriven @SupportsBatching @Tags({"grpc", "rpc", "client"}) @InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)