Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-7629: Make property PROJECT_ID evaluate EL on processors ConsumeGCPubSub & PublishGCPubSub

This commit is contained in:
Cuong Nguyen 2020-07-11 12:12:46 +07:00 committed by markap14
parent 19a84dd3dd
commit c7a235f854
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/ConsumeGCPubSub.java
View File

@ -179,7 +179,7 @@ public class ConsumeGCPubSub extends AbstractGCPubSubProcessor {
private String getSubscriptionName(ProcessContext context) {
final String subscriptionName = context.getProperty(SUBSCRIPTION).evaluateAttributeExpressions().getValue();
final String projectId = context.getProperty(PROJECT_ID).getValue();
final String projectId = context.getProperty(PROJECT_ID).evaluateAttributeExpressions().getValue();
if (subscriptionName.contains("/")) {
return ProjectSubscriptionName.parse(subscriptionName).toString();

2
nifi-nar-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java
View File

@ -209,7 +209,7 @@ public class PublishGCPubSub extends AbstractGCPubSubProcessor{
private ProjectTopicName getTopicName(ProcessContext context) {
final String topic = context.getProperty(TOPIC_NAME).evaluateAttributeExpressions().getValue();
final String projectId = context.getProperty(PROJECT_ID).getValue();
final String projectId = context.getProperty(PROJECT_ID).evaluateAttributeExpressions().getValue();
if (topic.contains("/")) {
return ProjectTopicName.parse(topic);