Repository: nifi Updated Branches: refs/heads/develop 4b9ee460a -> 33279fd9d
NIFI-831, NIFI-799: Fixed a NullPointerException; use a buffer size of 10,000 messages instead of 100,000 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/33279fd9 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/33279fd9 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/33279fd9 Branch: refs/heads/develop Commit: 33279fd9d7f93f23137e8259febf709f50306012 Parents: 4b9ee46 Author: Mark Payne <[email protected]> Authored: Sat Aug 8 15:52:49 2015 -0400 Committer: Mark Payne <[email protected]> Committed: Sat Aug 8 15:52:49 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/twitter/GetTwitter.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/33279fd9/nifi/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java b/nifi/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java index a056867..f24b086 100644 --- a/nifi/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java +++ b/nifi/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java @@ -142,7 +142,7 @@ public class GetTwitter extends AbstractProcessor { private final BlockingQueue<Event> eventQueue = new LinkedBlockingQueue<>(1000); private volatile Client client; - private volatile BlockingQueue<String> messageQueue; + private volatile BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>(10000); @Override protected void init(final ProcessorInitializationContext context) { @@ -200,14 +200,12 @@ public class GetTwitter extends AbstractProcessor { @Override public void onPropertyModified(final PropertyDescriptor descriptor, final String oldValue, final String newValue) { - // if any property is modified, the results are no longer valid. Destroy all messages in teh queue. + // if any property is modified, the results are no longer valid. Destroy all messages in the queue. messageQueue.clear(); } @OnScheduled public void onScheduled(final ProcessContext context) throws MalformedURLException { - messageQueue = new LinkedBlockingQueue<>(100000); - final String endpointName = context.getProperty(ENDPOINT).getValue(); final Authentication oauth = new OAuth1(context.getProperty(CONSUMER_KEY).getValue(), context.getProperty(CONSUMER_SECRET).getValue(),
