message handling on receiving
parent
2783f61f7e
commit
131d3d85cb
|
@ -17,13 +17,13 @@ public class KraSocketClientProtocol {
|
|||
private final ArrayList<Integer> cmdIDs;
|
||||
@Getter
|
||||
private int currentCmdIDIndex;
|
||||
|
||||
//@Getter
|
||||
//HashMap<Integer, Consumer<KraSocketClientProtocolMessage>> consumerHashMap = new HashMap<>();
|
||||
@Getter
|
||||
private final HashMap<Integer, Consumer<KraSocketClientProtocolMessage>> consumerHashMap;
|
||||
|
||||
public KraSocketClientProtocol() {
|
||||
this.cmdIDs = new ArrayList<>();
|
||||
this.currentCmdIDIndex = 10;
|
||||
this.consumerHashMap = new HashMap<>();
|
||||
}
|
||||
|
||||
public int generateCmdID() {
|
||||
|
@ -45,7 +45,7 @@ public class KraSocketClientProtocol {
|
|||
kraProtocolMessage.getDest(), kraProtocolMessage.getUuid(),
|
||||
kraProtocolMessage.getCmdNumber(), kraProtocolMessage.getArgs());
|
||||
}
|
||||
|
||||
|
||||
public byte[] EncodeMessage(int status, int cmdID, int dest, String uuid, int cmdNumber,
|
||||
String args) {
|
||||
KraSocketClient.getLogger()
|
||||
|
@ -84,7 +84,6 @@ public class KraSocketClientProtocol {
|
|||
this.cmdIDs.add(cmdID);
|
||||
|
||||
return raw;
|
||||
//ProxySystem.getInstance().getSocketClient().SendMessage(raw);
|
||||
}
|
||||
|
||||
public KraSocketClientProtocolMessage DecodeMessage(byte[] data) {
|
||||
|
|
Loading…
Reference in New Issue