dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Issue #1686 Add registerSyncSession to case TO_SERVER_RPC_REQUEST to enable

Browse Source 
CoAP RPC Server request calls.
This commit is contained in:
Mike Lohmann 2019-05-07 23:12:00 +02:00 committed by Jan Christoph Bernack
parent ab494596e7
commit 6b47046bdb
No known key found for this signature in database
GPG Key ID: BD807E5761329D0A
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
common/transport/coap/src/main/java/org/thingsboard/server/transport/coap/CoapTransportResource.java
View File

@ -192,6 +192,7 @@ public class CoapTransportResource extends CoapResource {
new CoapOkCallback(exchange)); new CoapOkCallback(exchange));
break; break;
case TO_SERVER_RPC_REQUEST: case TO_SERVER_RPC_REQUEST:
transportService.registerSyncSession(sessionInfo, new CoapSessionListener(sessionId, exchange), transportContext.getTimeout());
transportService.process(sessionInfo, transportService.process(sessionInfo,
transportContext.getAdaptor().convertToServerRpcRequest(sessionId, request), transportContext.getAdaptor().convertToServerRpcRequest(sessionId, request),
new CoapNoOpCallback(exchange)); new CoapNoOpCallback(exchange));
@ -392,6 +393,7 @@ public class CoapTransportResource extends CoapResource {
@Override @Override
public void onToServerRpcResponse(TransportProtos.ToServerRpcResponseMsg msg) { public void onToServerRpcResponse(TransportProtos.ToServerRpcResponseMsg msg) {
try { try {
log.info("onToServerRpcResponse called");
exchange.respond(transportContext.getAdaptor().convertToPublish(this, msg)); exchange.respond(transportContext.getAdaptor().convertToPublish(this, msg));
} catch (AdaptorException e) { } catch (AdaptorException e) {
log.trace("Failed to reply due to error", e); log.trace("Failed to reply due to error", e);