简柏林 / thingskit · Commits

Commit d25c605ac617be3ccfeae644fa3f3b22325f4b3d

Authored by Sergey Matvienko
1 parent 4c081289

DefaultTbCoreToTransportService: fire "onSuccess send" when skipping message without nodeId

Inline Side-by-side
Showing 1 changed file with 3 additions and 0 deletions
@@ -56,6 +56,9 @@ public class DefaultTbCoreToTransportService implements TbCoreToTransportService @@ -56,6 +56,9 @@ public class DefaultTbCoreToTransportService implements TbCoreToTransportService
56 public void process(String nodeId, ToTransportMsg msg, Runnable onSuccess, Consumer<Throwable> onFailure) { 56 public void process(String nodeId, ToTransportMsg msg, Runnable onSuccess, Consumer<Throwable> onFailure) {
57 if (nodeId == null || nodeId.isEmpty()){ 57 if (nodeId == null || nodeId.isEmpty()){
58 log.trace("process: skipping message without nodeId [{}], (ToTransportMsg) msg [{}]", nodeId, msg); 58 log.trace("process: skipping message without nodeId [{}], (ToTransportMsg) msg [{}]", nodeId, msg);
  59 + if (onSuccess != null) {
  60 + onSuccess.run();
  61 + }
59 return; 62 return;
60 } 63 }
61 TopicPartitionInfo tpi = partitionService.getNotificationsTopic(ServiceType.TB_TRANSPORT, nodeId); 64 TopicPartitionInfo tpi = partitionService.getNotificationsTopic(ServiceType.TB_TRANSPORT, nodeId);