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

This closes #2083.

Signed-off-by: Koji Kawamura <ijokarumawak@apache.org>
This commit is contained in:
Mark Payne 2017-08-14 13:23:35 -04:00 committed by Koji Kawamura
parent cb7bc93e28
commit d698f227df
1 changed files with 4 additions and 0 deletions

View File

@ -192,6 +192,10 @@ public class PublisherLease implements Closeable {
}
public InFlightMessageTracker getTracker() {
if (tracker == null) {
tracker = new InFlightMessageTracker();
}
return tracker;
}
}