Browse Source

'Store' value type changed from String to Object

master
Nikita 11 years ago
parent
commit
9572688f8f
  1. 8
      src/main/java/com/corundumstudio/socketio/store/HazelcastStore.java
  2. 8
      src/main/java/com/corundumstudio/socketio/store/MemoryStore.java
  3. 8
      src/main/java/com/corundumstudio/socketio/store/RedissonStore.java
  4. 4
      src/main/java/com/corundumstudio/socketio/store/Store.java
  5. 4
      src/main/java/com/corundumstudio/socketio/transport/NamespaceClient.java

8
src/main/java/com/corundumstudio/socketio/store/HazelcastStore.java

@ -23,20 +23,20 @@ import com.hazelcast.core.IMap;
public class HazelcastStore implements Store {
private final IMap<String, String> map;
private final IMap<String, Object> map;
public HazelcastStore(UUID sessionId, HazelcastInstance hazelcastInstance) {
map = hazelcastInstance.getMap(sessionId.toString());
}
@Override
public void set(String key, String val) {
public void set(String key, Object val) {
map.put(key, val);
}
@Override
public String get(String key) {
return map.get(key);
public <T> T get(String key) {
return (T) map.get(key);
}
@Override

8
src/main/java/com/corundumstudio/socketio/store/MemoryStore.java

@ -20,16 +20,16 @@ import java.util.concurrent.ConcurrentHashMap;
public class MemoryStore implements Store {
private final Map<String, String> store = new ConcurrentHashMap<String, String>();
private final Map<String, Object> store = new ConcurrentHashMap<String, Object>();
@Override
public void set(String key, String value) {
public void set(String key, Object value) {
store.put(key, value);
}
@Override
public String get(String key) {
return store.get(key);
public <T> T get(String key) {
return (T) store.get(key);
}
@Override

8
src/main/java/com/corundumstudio/socketio/store/RedissonStore.java

@ -22,20 +22,20 @@ import org.redisson.Redisson;
public class RedissonStore implements Store {
private final Map<String, String> map;
private final Map<String, Object> map;
public RedissonStore(UUID sessionId, Redisson redisson) {
this.map = redisson.getMap(sessionId.toString());
}
@Override
public void set(String key, String value) {
public void set(String key, Object value) {
map.put(key, value);
}
@Override
public String get(String key) {
return map.get(key);
public <T> T get(String key) {
return (T) map.get(key);
}
@Override

4
src/main/java/com/corundumstudio/socketio/store/Store.java

@ -18,9 +18,9 @@ package com.corundumstudio.socketio.store;
public interface Store {
void set(String key, String val);
void set(String key, Object val);
String get(String key);
<T> T get(String key);
boolean has(String key);

4
src/main/java/com/corundumstudio/socketio/transport/NamespaceClient.java

@ -178,12 +178,12 @@ public class NamespaceClient implements SocketIOClient {
}
@Override
public void set(String key, String val) {
public void set(String key, Object val) {
baseClient.getStore().set(key, val);
}
@Override
public String get(String key) {
public <T> T get(String key) {
return baseClient.getStore().get(key);
}

Loading…
Cancel
Save