nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ijokaruma...@apache.org
Subject nifi git commit: NIFI-4290: Ensure that the InFlightMessageTracker is instantiated when getTracker() is called
Date Tue, 12 Sep 2017 01:40:12 GMT
Repository: nifi
Updated Branches:
  refs/heads/master cb7bc93e2 -> d698f227d


NIFI-4290: Ensure that the InFlightMessageTracker is instantiated when getTracker() is called

This closes #2083.

Signed-off-by: Koji Kawamura <ijokarumawak@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d698f227
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d698f227
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d698f227

Branch: refs/heads/master
Commit: d698f227df09743148067ec183bcf2f672a8a8c4
Parents: cb7bc93
Author: Mark Payne <markap14@hotmail.com>
Authored: Mon Aug 14 13:23:35 2017 -0400
Committer: Koji Kawamura <ijokarumawak@apache.org>
Committed: Tue Sep 12 10:30:44 2017 +0900

----------------------------------------------------------------------
 .../org/apache/nifi/processors/kafka/pubsub/PublisherLease.java  | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/d698f227/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
index 8603bbc..70957ce 100644
--- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
+++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
@@ -192,6 +192,10 @@ public class PublisherLease implements Closeable {
     }
 
     public InFlightMessageTracker getTracker() {
+        if (tracker == null) {
+            tracker = new InFlightMessageTracker();
+        }
+
         return tracker;
     }
 }


Mime
View raw message