add listener redis

mpush-tools/src/main/java/com/shinemo/mpush/tools/redis/listener/ListenerDispatcher.java

@@ -0,0 +1,27 @@
+package com.shinemo.mpush.tools.redis.listener;
+
+import java.util.Iterator;
+import java.util.Map;
+
+import com.google.common.collect.Maps;
+
+public class ListenerDispatcher implements MessageListener {
+
+	private Map<String, MessageListener> holder = Maps.newTreeMap();
+
+	public static ListenerDispatcher instance = new ListenerDispatcher();
+
+	private ListenerDispatcher() {
+	}
+
+	@Override
+	public void onMessage(String channel, String message) {
+		Iterator<Map.Entry<String, MessageListener>> it = holder.entrySet().iterator();
+		while (it.hasNext()) {
+			Map.Entry<String, MessageListener> entry = it.next();
+			entry.getValue().onMessage(channel, message);
+		}
+	}
+
+
+}

mpush-tools/src/main/java/com/shinemo/mpush/tools/redis/listener/MessageListener.java

@@ -0,0 +1,8 @@
+package com.shinemo.mpush.tools.redis.listener;
+
+
+public interface MessageListener {
+
+	void onMessage(String channel, String message);
+
+}

mpush-tools/src/main/java/com/shinemo/mpush/tools/redis/pubsub/Subscriber.java

@@ -3,15 +3,20 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.shinemo.mpush.tools.redis.listener.ListenerDispatcher;
+
 import redis.clients.jedis.JedisPubSub;
 
 public class Subscriber extends JedisPubSub{
 
 	private static final Logger log = LoggerFactory.getLogger(Subscriber.class);
 
+	private ListenerDispatcher dispatcher = ListenerDispatcher.instance;
+
 	@Override
 	public void onMessage(String channel, String message) {
 		log.warn("onMessage channel:"+channel+","+message);
+		dispatcher.onMessage(channel, message);
 		super.onMessage(channel, message);
 	}