Generic to "subscribe" method added.

src/main/java/com/corundumstudio/socketio/store/pubsub/PubSubMemoryStore.java

@@ -22,7 +22,7 @@ public class PubSubMemoryStore implements PubSubStore {
     }
 
     @Override
-    public void subscribe(String name, PubSubListener listener, Class clazz) {
+    public <T> void subscribe(String name, PubSubListener<T> listener, Class<T> clazz) {
     }
 
     @Override

src/main/java/com/corundumstudio/socketio/store/pubsub/PubSubRedisStore.java

@@ -124,7 +124,7 @@ public class PubSubRedisStore implements PubSubStore {
     }
 
     @Override
-    public void subscribe(final String name, PubSubListener listener, Class clazz) {
+    public <T> void subscribe(final String name, PubSubListener<T> listener, Class<T> clazz) {
         Queue<PubSubListener> list = map.get(name);
         if (list == null) {
             list = new ConcurrentLinkedQueue<PubSubListener>();

src/main/java/com/corundumstudio/socketio/store/pubsub/PubSubStore.java

@@ -27,7 +27,7 @@ public interface PubSubStore {
 
     void publish(String name, PubSubMessage msg);
 
-    void subscribe(String name, PubSubListener listener, Class clazz);
+    <T> void subscribe(String name, PubSubListener<T> listener, Class<T> clazz);
 
     void unsubscribe(String name);