源码分析：tb-core 的作用

通过前面的kafka消息队列分析，其他服务会将消息发送给 tb-core

【tb-core消息生产端】

TbClusterService.java 有下列相关的地方会将消息推送给tb-core：

public interface TbClusterService {
 
    //推送消息到tb-core
 
    public void pushMsgToCore(TopicPartitionInfo var1, UUID var2, TransportProtos.ToCoreMsg var3, TbQueueCallback var4);
 
    public void pushMsgToCore(TenantId var1, EntityId var2, TransportProtos.ToCoreMsg var3, TbQueueCallback var4);
 
    public void pushMsgToCore(ToDeviceActorNotificationMsg var1, TbQueueCallback var2);
 
    //推送通知到tb-core
 
    public void pushNotificationToCore(String var1, IntegrationDownlinkMsg var2, TbQueueCallback var3);
 
    public void pushNotificationToCore(String var1, FromDeviceRpcResponse var2, TbQueueCallback var3);
 
    public void pushNotificationToCore(String var1, TransportProtos.RestApiCallResponseMsgProto var2, TbQueueCallback var3);
 
}

DefaultTransportService.java 也有相关的从 tr