lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2018-06-01 10:31:00 +08:00
parent fa9e62d2a7
commit bdfdf153f7
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/org/redkale/boot/Application.java
View File

@@ -606,15 +606,15 @@ public final class Application {
buffer.flip(); buffer.flip();
channel.write(buffer); channel.write(buffer);
buffer.clear(); buffer.clear();
channel.configureBlocking(false); channel.configureBlocking(true);
try { try {
channel.read(buffer); channel.read(buffer);
buffer.flip(); buffer.flip();
byte[] bytes = new byte[buffer.remaining()]; byte[] bytes = new byte[buffer.remaining()];
buffer.get(bytes); buffer.get(bytes);
channel.close(); channel.close();
logger.info(new String(bytes)); logger.info("Send: " + command + ", Reply: " + new String(bytes));
Thread.sleep(500); Thread.sleep(1000);
} catch (Exception e) { } catch (Exception e) {
if (e instanceof PortUnreachableException) { if (e instanceof PortUnreachableException) {
if ("APIDOC".equalsIgnoreCase(command)) { if ("APIDOC".equalsIgnoreCase(command)) {