Fix a bug with re-sending messages

This commit is contained in:
Mario Danic 2018-10-16 22:01:32 +02:00
parent 0bb65795ad
commit 5a3f199f14

View File

@ -40,9 +40,6 @@ import org.greenrobot.eventbus.EventBus;
import java.io.IOException; import java.io.IOException;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.Random;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import javax.inject.Inject; import javax.inject.Inject;
@ -72,7 +69,7 @@ public class MagicWebSocketInstance extends WebSocketListener {
private boolean connected; private boolean connected;
private WebSocketConnectionHelper webSocketConnectionHelper; private WebSocketConnectionHelper webSocketConnectionHelper;
private WebSocket webSocket; private WebSocket webSocket;
private MagicMap<Integer, Object> magicMap; private MagicMap magicMap;
MagicWebSocketInstance(UserEntity conversationUser, String connectionUrl, String webSocketTicket) { MagicWebSocketInstance(UserEntity conversationUser, String connectionUrl, String webSocketTicket) {
NextcloudTalkApplication.getSharedApplication().getComponentApplication().inject(this); NextcloudTalkApplication.getSharedApplication().getComponentApplication().inject(this);
@ -215,8 +212,8 @@ public class MagicWebSocketInstance extends WebSocketListener {
} }
public Object getJobWithId(Integer id) { public Object getJobWithId(Integer id) {
Object copyJob = concurrentHashMapQueue.get(id); Object copyJob = magicMap.get(id);
concurrentHashMapQueue.remove(id); magicMap.remove(id);
return copyJob; return copyJob;
} }