Sorry, this isn't even being used.
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/4f30bd2a Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/4f30bd2a Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/4f30bd2a Branch: refs/heads/master Commit: 4f30bd2a8cec2869765fa875d303e98492242b7b Parents: 651be79 Author: Matthew Hager <matthew.ha...@gmail.com> Authored: Mon May 5 16:37:53 2014 -0500 Committer: Matthew Hager <matthew.ha...@gmail.com> Committed: Mon May 5 16:37:53 2014 -0500 ---------------------------------------------------------------------- .../apache/streams/s3/S3PersistWriterTask.java | 37 -------------------- 1 file changed, 37 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/4f30bd2a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriterTask.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriterTask.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriterTask.java deleted file mode 100644 index d791c87..0000000 --- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriterTask.java +++ /dev/null @@ -1,37 +0,0 @@ -package org.apache.streams.s3; - -import org.apache.streams.core.StreamsDatum; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.Random; - -public class S3PersistWriterTask implements Runnable { - - private static final Logger LOGGER = LoggerFactory.getLogger(S3PersistWriterTask.class); - - private S3PersistWriter writer; - - public S3PersistWriterTask(S3PersistWriter writer) { - this.writer = writer; - } - - @Override - public void run() { - while(true) { - if( writer.persistQueue.peek() != null ) { - try { - StreamsDatum entry = writer.persistQueue.remove(); - writer.write(entry); - } catch (Exception e) { - e.printStackTrace(); - } - } - try { - Thread.sleep(new Random().nextInt(1)); - } catch (InterruptedException e) {} - } - - } - -}
