timeabarna commented on a change in pull request #5593:
URL: https://github.com/apache/nifi/pull/5593#discussion_r806488746
##########
File path:
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/controller/StandardFunnel.java
##########
@@ -577,6 +588,58 @@ public String getComponentType() {
return "Funnel";
}
+ @Override
+ public int getRetryCount() {
+ return 0;
+ }
+
+ @Override
+ public void setRetryCount(Integer retryCount) {
+ this.retryCount = retryCount;
+ }
+
+ @Override
+ public Set<String> getRetriedRelationships() {
+ return Collections.EMPTY_SET;
+ }
+
+ @Override
+ public void setRetriedRelationships(Set<String> retriedRelationships) {
+ this.retriedRelationships = (retriedRelationships == null) ?
Collections.emptySet() : new HashSet<>(retriedRelationships);
+ }
+
+ @Override
+ public boolean isRelationshipRetried(Relationship relationship) {
+ return false;
+ }
+
+ @Override
+ public BackoffMechanism getBackoffMechanism() {
+ return BackoffMechanism.PENALIZE_FLOWFILE;
+ }
+
+ @Override
+ public void setBackoffMechanism(BackoffMechanism backoffMechanism) {
+ this.backoffMechanism = (backoffMechanism == null) ?
BackoffMechanism.PENALIZE_FLOWFILE : backoffMechanism;
+ }
+
+ @Override
+ public String getMaxBackoffPeriod() {
+ return DEFAULT_MAX_BACKOFF_PERIOD;
+ }
+
+ @Override
+ public void setMaxBackoffPeriod(String maxBackoffPeriod) {
+ if (maxBackoffPeriod == null) {
+ maxBackoffPeriod = DEFAULT_MAX_BACKOFF_PERIOD;
+ }
+ final long backoffNanos =
FormatUtils.getTimeDuration(maxBackoffPeriod, TimeUnit.NANOSECONDS);
+ if (backoffNanos < 0) {
+ throw new IllegalArgumentException("Max Backoff Period must be
positive");
+ }
+ this.maxBackoffPeriod = maxBackoffPeriod;
Review comment:
Setters are required because of Connectable interface. Implementing them
with doing nothing.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
