From 6b47046bdbb29fcc57bd0032f7deb6add4efccf7 Mon Sep 17 00:00:00 2001 From: Mike Lohmann Date: Tue, 7 May 2019 23:12:00 +0200 Subject: [PATCH] Issue #1686 Add registerSyncSession to case TO_SERVER_RPC_REQUEST to enable CoAP RPC Server request calls. --- .../server/transport/coap/CoapTransportResource.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/common/transport/coap/src/main/java/org/thingsboard/server/transport/coap/CoapTransportResource.java b/common/transport/coap/src/main/java/org/thingsboard/server/transport/coap/CoapTransportResource.java index 4392a04d2a..705e7178e0 100644 --- a/common/transport/coap/src/main/java/org/thingsboard/server/transport/coap/CoapTransportResource.java +++ b/common/transport/coap/src/main/java/org/thingsboard/server/transport/coap/CoapTransportResource.java @@ -192,6 +192,7 @@ public class CoapTransportResource extends CoapResource { new CoapOkCallback(exchange)); break; case TO_SERVER_RPC_REQUEST: + transportService.registerSyncSession(sessionInfo, new CoapSessionListener(sessionId, exchange), transportContext.getTimeout()); transportService.process(sessionInfo, transportContext.getAdaptor().convertToServerRpcRequest(sessionId, request), new CoapNoOpCallback(exchange)); @@ -392,6 +393,7 @@ public class CoapTransportResource extends CoapResource { @Override public void onToServerRpcResponse(TransportProtos.ToServerRpcResponseMsg msg) { try { + log.info("onToServerRpcResponse called"); exchange.respond(transportContext.getAdaptor().convertToPublish(this, msg)); } catch (AdaptorException e) { log.trace("Failed to reply due to error", e);