umarhussain15 commented on code in PR #8105:
URL: https://github.com/apache/nifi/pull/8105#discussion_r1685537813
##########
nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/PublishAMQP.java:
##########
@@ -96,13 +96,44 @@ public class PublishAMQP extends
AbstractAMQPProcessor<AMQPPublisher> {
.expressionLanguageSupported(ExpressionLanguageScope.FLOWFILE_ATTRIBUTES)
.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
.build();
-
+ public static final PropertyDescriptor HEADERS_SOURCE = new
PropertyDescriptor.Builder()
+ .name("Headers Source")
+ .displayName("Headers Source")
+ .description(
+ "The source of the headers which will be put in the
published message. They can come either from the processor property as a string
or they can be " +
+ "picked from flow file attributes based on Regex
expression.")
+ .required(true)
+ .allowableValues(InputHeaderSource.getAllowedValues())
+ .defaultValue(InputHeaderSource.STRING)
+ .build();
+ public static final PropertyDescriptor HEADERS_SOURCE_PRECEDENCE = new
PropertyDescriptor.Builder()
+ .name("Headers Source Precedence")
Review Comment:
I have removed this option now
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@nifi.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
