NIFI-1176: Use a smaller internal blocking queue size of only 5000 messages; do not create a new queue every time the processor is scheduled to run
Signed-off-by: Aldrin Piri <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/180ea1ba Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/180ea1ba Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/180ea1ba Branch: refs/heads/NIFI-655 Commit: 180ea1ba222a5890541dfbe046f2876695e69239 Parents: 93be753 Author: Mark Payne <[email protected]> Authored: Mon Nov 16 15:50:14 2015 -0500 Committer: Aldrin Piri <[email protected]> Committed: Wed Nov 18 10:51:22 2015 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/processors/twitter/GetTwitter.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/180ea1ba/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java index e41b583..e099449 100644 --- a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java +++ b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java @@ -156,7 +156,7 @@ public class GetTwitter extends AbstractProcessor { private final BlockingQueue<Event> eventQueue = new LinkedBlockingQueue<>(1000); private volatile Client client; - private volatile BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>(10000); + private volatile BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>(5000); @Override protected void init(final ProcessorInitializationContext context) { @@ -222,8 +222,6 @@ public class GetTwitter extends AbstractProcessor { @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(),
