added use cases

Author: phasenraum2010

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/common/UserListsSplitter.java

@@ -0,0 +1,12 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.common;
+
+import org.springframework.messaging.Message;
+import org.woehlke.twitterwall.scheduled.mq.msg.TaskMessage;
+import org.woehlke.twitterwall.scheduled.mq.msg.UserListMessage;
+
+import java.util.List;
+
+public interface UserListsSplitter {
+
+    List<Message<UserListMessage>> splitUserListMessage(Message<TaskMessage> incomingTaskMessage);
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/FavoritesSplitter.java

@@ -0,0 +1,6 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets;
+
+import org.woehlke.twitterwall.scheduled.mq.endpoint.common.TweetsSplitter;
+
+public interface FavoritesSplitter extends TweetsSplitter {
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/HomeTimelineSplitter.java

@@ -0,0 +1,6 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets;
+
+import org.woehlke.twitterwall.scheduled.mq.endpoint.common.TweetsSplitter;
+
+public interface HomeTimelineSplitter  extends TweetsSplitter {
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/MentionsSplitter.java

@@ -0,0 +1,6 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets;
+
+import org.woehlke.twitterwall.scheduled.mq.endpoint.common.TweetsSplitter;
+
+public interface MentionsSplitter extends TweetsSplitter {
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/RetweetsOfMeSplitter.java

@@ -0,0 +1,6 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets;
+
+import org.woehlke.twitterwall.scheduled.mq.endpoint.common.TweetsSplitter;
+
+public interface RetweetsOfMeSplitter extends TweetsSplitter{
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/UserTimelineSplitter.java

@@ -0,0 +1,6 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets;
+
+import org.woehlke.twitterwall.scheduled.mq.endpoint.common.TweetsSplitter;
+
+public interface UserTimelineSplitter extends TweetsSplitter{
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/impl/FavoritesSplitterImpl.java

@@ -0,0 +1,17 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.impl;
+
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+import org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.FavoritesSplitter;
+import org.woehlke.twitterwall.scheduled.mq.msg.TaskMessage;
+import org.woehlke.twitterwall.scheduled.mq.msg.TweetMessage;
+
+import java.util.List;
+
+@Component("mqFavoritesSplitter")
+public class FavoritesSplitterImpl implements FavoritesSplitter {
+    @Override
+    public List<Message<TweetMessage>> splitTweetMessage(Message<TaskMessage> message) {
+        return null;
+    }
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/impl/HomeTimelineSplitterImpl.java

@@ -0,0 +1,18 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.impl;
+
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+import org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.HomeTimelineSplitter;
+import org.woehlke.twitterwall.scheduled.mq.msg.TaskMessage;
+import org.woehlke.twitterwall.scheduled.mq.msg.TweetMessage;
+
+import java.util.List;
+
+@Component("mqHomeTimelineSplitter")
+public class HomeTimelineSplitterImpl implements HomeTimelineSplitter {
+
+    @Override
+    public List<Message<TweetMessage>> splitTweetMessage(Message<TaskMessage> message) {
+        return null;
+    }
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/impl/MentionsSplitterImpl.java

@@ -0,0 +1,17 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.impl;
+
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+import org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.MentionsSplitter;
+import org.woehlke.twitterwall.scheduled.mq.msg.TaskMessage;
+import org.woehlke.twitterwall.scheduled.mq.msg.TweetMessage;
+
+import java.util.List;
+
+@Component("mqMentionsSplitter")
+public class MentionsSplitterImpl implements MentionsSplitter {
+    @Override
+    public List<Message<TweetMessage>> splitTweetMessage(Message<TaskMessage> message) {
+        return null;
+    }
+}

src/main/java/org/woehlke/twitterwall/scheduled/mq/endpoint/tweets/impl/RetweetsOfMeSplitterImpl.java

@@ -0,0 +1,18 @@
+package org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.impl;
+
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+import org.woehlke.twitterwall.scheduled.mq.endpoint.tweets.RetweetsOfMeSplitter;
+import org.woehlke.twitterwall.scheduled.mq.msg.TaskMessage;
+import org.woehlke.twitterwall.scheduled.mq.msg.TweetMessage;
+
+import java.util.List;
+
+@Component("mqRetweetsOfMeSplitter")
+public class RetweetsOfMeSplitterImpl implements RetweetsOfMeSplitter {
+
+    @Override
+    public List<Message<TweetMessage>> splitTweetMessage(Message<TaskMessage> message) {
+        return null;
+    }
+}