parent
2aa379bf21
commit
69de9f6684
|
@ -68,7 +68,7 @@ public class StoredMessages {
|
||||||
jedis = jedisPool.getResource();
|
jedis = jedisPool.getResource();
|
||||||
String message;
|
String message;
|
||||||
|
|
||||||
while ((message = jedis.rpop(QUEUE_PREFIX + accountId + ":" + deviceId)) != null) {
|
while ((message = jedis.rpop(getKey(accountId, deviceId))) != null) {
|
||||||
messages.add(message);
|
messages.add(message);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue