|
|
|
@ -176,7 +176,8 @@ public class GatewaySessionHandler { |
|
|
|
TransportProtos.PostTelemetryMsg postTelemetryMsg = JsonConverter.convertToTelemetryProto(deviceEntry.getValue().getAsJsonArray()); |
|
|
|
transportService.process(deviceCtx.getSessionInfo(), postTelemetryMsg, getPubAckCallback(channel, deviceName, msgId, postTelemetryMsg)); |
|
|
|
} catch (Throwable e) { |
|
|
|
log.warn("Failed to post telemetry.", e); |
|
|
|
UUID gatewayId = new UUID(gateway.getDeviceIdMSB(), gateway.getDeviceIdLSB()); |
|
|
|
log.warn("[{}][{}] Failed to convert telemetry: {}", gatewayId, deviceName, deviceEntry.getValue(), e); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
@ -208,7 +209,6 @@ public class GatewaySessionHandler { |
|
|
|
TransportProtos.PostAttributeMsg postAttributeMsg = JsonConverter.convertToAttributesProto(deviceEntry.getValue().getAsJsonObject()); |
|
|
|
transportService.process(deviceCtx.getSessionInfo(), postAttributeMsg, getPubAckCallback(channel, deviceName, msgId, postAttributeMsg)); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onFailure(Throwable t) { |
|
|
|
log.debug("[{}] Failed to process device attributes command: {}", sessionId, deviceName, t); |
|
|
|
|