SOCIAL-483: Add support for non-Tweet stream events

spring-social-twitter/src/main/java/org/springframework/social/twitter/api/StreamListener.java

@@ -15,6 +15,8 @@
  */
 package org.springframework.social.twitter.api;
 
+import java.util.Map;
+
 /**
  * Listener interface for clients consuming data from a Twitter stream.
  * @author Craig Walls
@@ -44,5 +46,6 @@ public interface StreamListener {
 	 * @param warningEvent a warning event
 	 */
 	void onWarning(StreamWarningEvent warningEvent);
-
+
+	void onEvent(Map event);
 }

spring-social-twitter/src/main/java/org/springframework/social/twitter/api/impl/StreamDispatcher.java

@@ -17,6 +17,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.Map;
 import java.util.Queue;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -68,6 +69,8 @@ public void run() {
 					handleDelete(line);
 				} else if (line.startsWith("{\"warning")) {
 					handleWarning(line);
+				} else {
+					handleEvent(line);
 				}
 			} catch (IOException e) {
 				// TODO: Should only happen if Jackson doesn't know how to map the line
@@ -123,5 +126,16 @@ public void run() {
 			}));
 		}
 	}
+
+	private void handleEvent(String line) throws IOException {
+		final Map event = objectMapper.readValue(line, Map.class);
+		for (final StreamListener listener : listeners) {
+			Future<?> result = pool.submit((new Runnable() {
+				public void run() {
+					listener.onEvent(event);
+				}
+			}));
+		}
+	}
 
 }

spring-social-twitter/src/test/java/org/springframework/social/twitter/api/impl/StreamingTemplateTest.java

@@ -24,6 +24,7 @@
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.Map;
 
 import org.junit.Ignore;
 import org.junit.Test;
@@ -114,6 +115,11 @@ public void onWarning(StreamWarningEvent warningEvent) {
 			messageReceived();
 		}
 
+		@Override
+		public void onEvent(Map event) {
+			messageReceived();
+		}
+
 		private void messageReceived() {
 			stopAfter--;
 			if(stopAfter == 0) {