Repository: nifi Updated Branches: refs/heads/master 23937835f -> 3719a6268
NIFI-5120 AbstractListenEventProcessor supports expression language Signed-off-by: Pierre Villard <[email protected]> This closes #2659. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/3719a626 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/3719a626 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/3719a626 Branch: refs/heads/master Commit: 3719a6268c3ff020ab3083751bd48e652e668695 Parents: 2393783 Author: sbouchex <[email protected]> Authored: Wed Apr 25 22:40:45 2018 +0200 Committer: Pierre Villard <[email protected]> Committed: Thu Apr 26 14:05:53 2018 +0200 ---------------------------------------------------------------------- .../nifi/processor/util/listen/AbstractListenEventProcessor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/3719a626/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventProcessor.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventProcessor.java b/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventProcessor.java index 8333ae2..20df868 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventProcessor.java +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/src/main/java/org/apache/nifi/processor/util/listen/AbstractListenEventProcessor.java @@ -22,6 +22,7 @@ import org.apache.commons.lang3.StringUtils; import org.apache.nifi.annotation.lifecycle.OnScheduled; import org.apache.nifi.annotation.lifecycle.OnUnscheduled; import org.apache.nifi.components.PropertyDescriptor; +import org.apache.nifi.expression.ExpressionLanguageScope; import org.apache.nifi.processor.AbstractProcessor; import org.apache.nifi.processor.DataUnit; import org.apache.nifi.processor.ProcessContext; @@ -62,6 +63,7 @@ public abstract class AbstractListenEventProcessor<E extends Event> extends Abst .Builder().name("Port") .description("The port to listen on for communication.") .required(true) + .expressionLanguageSupported(ExpressionLanguageScope.VARIABLE_REGISTRY) .addValidator(StandardValidators.PORT_VALIDATOR) .build(); public static final PropertyDescriptor CHARSET = new PropertyDescriptor.Builder() @@ -175,7 +177,7 @@ public abstract class AbstractListenEventProcessor<E extends Event> extends Abst @OnScheduled public void onScheduled(final ProcessContext context) throws IOException { charset = Charset.forName(context.getProperty(CHARSET).getValue()); - port = context.getProperty(PORT).asInteger(); + port = context.getProperty(PORT).evaluateAttributeExpressions().asInteger(); events = new LinkedBlockingQueue<>(context.getProperty(MAX_MESSAGE_QUEUE_SIZE).asInteger()); final String nicIPAddressStr = context.getProperty(NETWORK_INTF_NAME).evaluateAttributeExpressions().getValue();
