Browse Source

fix: decode 활성화

feature/socket
지대한 7 months ago
parent
commit
9641c5ccf3
  1. 3
      app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/codec/DronDecoder.java
  2. 4
      app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/codec/DronEncoder.java
  3. 2
      app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/command/impl/SandboxDronCommandImpl.java
  4. 2
      app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/handler/DronHandler.java

3
app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/codec/DronDecoder.java

@ -21,9 +21,6 @@ public class DronDecoder extends MessageToMessageDecoder<String> {
protected void decode(ChannelHandlerContext ctx, String in, List<Object> out) throws Exception {
log.info(">>>>> decode <<<<<");
try {
// TypeReference<DronRQ> typeRef = new TypeReference<DronRQ>() {
// };
// DronRQ payload = objectMapper.readValue(in, typeRef);
DronRq payload = objectMapper.readValue(in, DronRq.class);
if (payload != null) {
out.add(payload);

4
app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/codec/DronEncoder.java

@ -19,8 +19,8 @@ public class DronEncoder extends MessageToMessageEncoder<Object> {
protected void encode(ChannelHandlerContext ctx, Object msg, List<Object> out) throws Exception {
log.info(">>>>> encode <<<");
try {
// String json = objectMapper.writeValueAsString(msg);
// out.add(json);
String json = objectMapper.writeValueAsString(msg);
out.add(json);
} catch (Exception e) {
log.warn("json parsing error : {} :: {}", e.getMessage(), msg);
}

2
app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/command/impl/SandboxDronCommandImpl.java

@ -133,7 +133,7 @@ public class SandboxDronCommandImpl implements DronCommand {
}
Long end = System.currentTimeMillis();
log.info(">>> during time : {}::{}", dron.getObjectId(), end - start);
log.info(">>> during time : {} - {}", dron.getObjectId(), end - start);
} else {
log.error("좌표 정보가 존재하지 않습니다.");

2
app/kac-socket-app/src/main/java/kr/co/palnet/kac/socket/core/handler/DronHandler.java

@ -67,7 +67,9 @@ public class DronHandler extends SimpleChannelInboundHandler<DronRq> {
}
log.info(">>> rq : {}", rq);
DronCommand commandService = commandMap.get(rq.getCommand().trim());
if (commandService == null) {
ctx.writeAndFlush(DronRs.builder()
.code("-2100")

Loading…
Cancel
Save