StoreFactories renamed.

src/main/java/com/corundumstudio/socketio/store/PubSubHazelcastStore.java → src/main/java/com/corundumstudio/socketio/store/HazelcastPubSubStore.java

@@ -29,7 +29,7 @@ import com.hazelcast.core.Message;
 import com.hazelcast.core.MessageListener;
 
 
-public class PubSubHazelcastStore implements PubSubStore {
+public class HazelcastPubSubStore implements PubSubStore {
 
     private final HazelcastInstance hazelcastPub;
     private final HazelcastInstance hazelcastSub;
@@ -38,7 +38,7 @@ public class PubSubHazelcastStore implements PubSubStore {
     private final ConcurrentMap<String, Queue<String>> map =
                                         new ConcurrentHashMap<String, Queue<String>>();
 
-    public PubSubHazelcastStore(HazelcastInstance hazelcastPub, HazelcastInstance hazelcastSub, Long nodeId) {
+    public HazelcastPubSubStore(HazelcastInstance hazelcastPub, HazelcastInstance hazelcastSub, Long nodeId) {
         this.hazelcastPub = hazelcastPub;
         this.hazelcastSub = hazelcastSub;
         this.nodeId = nodeId;

src/main/java/com/corundumstudio/socketio/store/HazelcastStoreFactory.java

@@ -60,7 +60,7 @@ public class HazelcastStoreFactory extends BaseStoreFactory {
 
     @Override
     public PubSubStore getPubSubStore() {
-        return new PubSubHazelcastStore(hazelcastPub, hazelcastSub, getNodeId());
+        return new HazelcastPubSubStore(hazelcastPub, hazelcastSub, getNodeId());
     }
 
 }

src/main/java/com/corundumstudio/socketio/store/PubSubMemoryStore.java → src/main/java/com/corundumstudio/socketio/store/MemoryPubSubStore.java

@@ -19,7 +19,7 @@ import com.corundumstudio.socketio.store.pubsub.PubSubListener;
 import com.corundumstudio.socketio.store.pubsub.PubSubMessage;
 import com.corundumstudio.socketio.store.pubsub.PubSubStore;
 
-public class PubSubMemoryStore implements PubSubStore {
+public class MemoryPubSubStore implements PubSubStore {
 
     @Override
     public void publish(String name, PubSubMessage msg) {

src/main/java/com/corundumstudio/socketio/store/MemoryStoreFactory.java

@@ -22,7 +22,7 @@ import com.corundumstudio.socketio.store.pubsub.PubSubStore;
 
 public class MemoryStoreFactory extends BaseStoreFactory {
 
-    private final PubSubMemoryStore pubSubMemoryStore = new PubSubMemoryStore();
+    private final MemoryPubSubStore pubSubMemoryStore = new MemoryPubSubStore();
 
     @Override
     public Store create(UUID sessionId) {

src/main/java/com/corundumstudio/socketio/store/PubSubRedisStore.java → src/main/java/com/corundumstudio/socketio/store/RedisPubSubStore.java

@@ -37,7 +37,7 @@ import com.corundumstudio.socketio.store.pubsub.PubSubListener;
 import com.corundumstudio.socketio.store.pubsub.PubSubMessage;
 import com.corundumstudio.socketio.store.pubsub.PubSubStore;
 
-public class PubSubRedisStore implements PubSubStore {
+public class RedisPubSubStore implements PubSubStore {
 
     private final ExecutorService executorService = Executors.newFixedThreadPool(5);
 
@@ -108,7 +108,7 @@ public class PubSubRedisStore implements PubSubStore {
         }
     };
 
-    public PubSubRedisStore(Jedis pub, Jedis sub, Long nodeId, JsonSupport jsonSupport) {
+    public RedisPubSubStore(Jedis pub, Jedis sub, Long nodeId, JsonSupport jsonSupport) {
         this.nodeId = nodeId;
         this.jsonSupport = jsonSupport;
         this.pub = pub;

src/main/java/com/corundumstudio/socketio/store/RedisStoreFactory.java

@@ -31,7 +31,7 @@ public class RedisStoreFactory extends BaseStoreFactory {
     private Jedis redisPub = new Jedis("127.0.0.1", 6379);
     private Jedis redisSub = new Jedis("127.0.0.1", 6379);
 
-    private PubSubRedisStore pubSubRedisStore;
+    private RedisPubSubStore pubSubRedisStore;
 
     public RedisStoreFactory() {
     }
@@ -44,7 +44,7 @@ public class RedisStoreFactory extends BaseStoreFactory {
 
     @Override
     public void init(NamespacesHub namespacesHub, JsonSupport jsonSupport) {
-        pubSubRedisStore = new PubSubRedisStore(redisPub, redisSub, getNodeId(), jsonSupport);
+        pubSubRedisStore = new RedisPubSubStore(redisPub, redisSub, getNodeId(), jsonSupport);
 
         redisClient.connect();
         redisPub.connect();