|
|
@ -44,6 +44,13 @@ public class ComWebsocketClient extends WebSocketClient { |
|
|
|
if ( requestItem.isResponseReceived ) { |
|
|
|
return ; |
|
|
|
} |
|
|
|
|
|
|
|
if ( requestItem.timeoutCount < 3 ) { |
|
|
|
requestItem.timeoutCount ++; |
|
|
|
write(requestItem.parameter); |
|
|
|
return ; |
|
|
|
} |
|
|
|
|
|
|
|
LOG.info("device -- timeout"); |
|
|
|
requestItem.response = null; |
|
|
|
requestItem.errorCode = ClientRequest.ERROR_CODE_TIMEOUT; |
|
|
@ -55,10 +62,7 @@ public class ComWebsocketClient extends WebSocketClient { |
|
|
|
timer.schedule(timerTask, 3000); |
|
|
|
|
|
|
|
synchronized (requestItem) { |
|
|
|
String cmd = MyByteBuffer.toHex(request.parameter); |
|
|
|
cmd = cmd.replace(" ",""); |
|
|
|
LOG.info("device => {}", cmd); |
|
|
|
this.send(cmd); |
|
|
|
this.write(requestItem.parameter); |
|
|
|
try { |
|
|
|
requestItem.wait(); |
|
|
|
} catch (InterruptedException e) { |
|
|
@ -68,6 +72,17 @@ public class ComWebsocketClient extends WebSocketClient { |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* write message to device |
|
|
|
* @param message message |
|
|
|
*/ |
|
|
|
public void write( ByteBuffer message ) { |
|
|
|
String cmd = MyByteBuffer.toHex(message); |
|
|
|
cmd = cmd.replace(" ",""); |
|
|
|
LOG.info("device => {}", cmd); |
|
|
|
this.send(cmd); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* event handler for receiving text message from device |
|
|
|
* @param text message from device |
|
|
|
*/ |
|
|
|