fixed #271

Author: phasenraum2010

src/main/java/org/woehlke/twitterwall/CronJobs.java

@@ -8,7 +8,7 @@
 import org.springframework.stereotype.Component;
 import org.woehlke.twitterwall.configuration.properties.SchedulerProperties;
 import org.woehlke.twitterwall.oodm.model.Task;
-import org.woehlke.twitterwall.backend.mq.endpoint.tasks.TaskStartFireAndForget;
+import org.woehlke.twitterwall.backend.mq.tasks.TaskStartFireAndForget;
 
 /**
  * Created by tw on 10.06.17.

src/main/java/org/woehlke/twitterwall/backend/mq/common/MentionSplitter.java

@@ -0,0 +1,12 @@
+package org.woehlke.twitterwall.backend.mq.common;
+
+import org.springframework.messaging.Message;
+import org.woehlke.twitterwall.backend.mq.mentions.msg.MentionMessage;
+import org.woehlke.twitterwall.backend.mq.tasks.TaskMessage;
+
+import java.util.List;
+
+public interface MentionSplitter {
+
+    List<Message<MentionMessage>> splitUserMessage(Message<TaskMessage> incomingTaskMessage);
+}

src/main/java/org/woehlke/twitterwall/backend/mq/common/TweetsSplitter.java

@@ -0,0 +1,12 @@
+package org.woehlke.twitterwall.backend.mq.common;
+
+import org.springframework.messaging.Message;
+import org.woehlke.twitterwall.backend.mq.tasks.TaskMessage;
+import org.woehlke.twitterwall.backend.mq.tweets.msg.TweetMessage;
+
+import java.util.List;
+
+public interface TweetsSplitter {
+
+    List<Message<TweetMessage>> splitTweetMessage(Message<TaskMessage> message);
+}

src/main/java/org/woehlke/twitterwall/backend/mq/endpoint/common/UrlSplitter.java renamed to src/main/java/org/woehlke/twitterwall/backend/mq/common/UrlSplitter.java

@@ -1,7 +1,7 @@
-package org.woehlke.twitterwall.backend.mq.endpoint.common;
+package org.woehlke.twitterwall.backend.mq.common;
 
 import org.springframework.messaging.Message;
-import org.woehlke.twitterwall.backend.mq.endpoint.urls.msg.UrlMessage;
+import org.woehlke.twitterwall.backend.mq.urls.msg.UrlMessage;
 
 import java.util.List;
 

src/main/java/org/woehlke/twitterwall/backend/mq/endpoint/common/UserListsSplitter.java renamed to src/main/java/org/woehlke/twitterwall/backend/mq/common/UserListsSplitter.java

@@ -1,8 +1,8 @@
-package org.woehlke.twitterwall.backend.mq.endpoint.common;
+package org.woehlke.twitterwall.backend.mq.common;
 
 import org.springframework.messaging.Message;
-import org.woehlke.twitterwall.backend.mq.endpoint.tasks.TaskMessage;
-import org.woehlke.twitterwall.backend.mq.endpoint.userlist.msg.UserListMessage;
+import org.woehlke.twitterwall.backend.mq.tasks.TaskMessage;
+import org.woehlke.twitterwall.backend.mq.userlist.msg.UserListMessage;
 
 import java.util.List;
 

src/main/java/org/woehlke/twitterwall/backend/mq/common/UserSplitter.java

@@ -0,0 +1,12 @@
+package org.woehlke.twitterwall.backend.mq.common;
+
+import org.springframework.messaging.Message;
+import org.woehlke.twitterwall.backend.mq.tasks.TaskMessage;
+import org.woehlke.twitterwall.backend.mq.users.msg.UserMessage;
+
+import java.util.List;
+
+public interface UserSplitter {
+
+    List<Message<UserMessage>> splitUserMessage(Message<TaskMessage> incomingTaskMessage);
+}