Showing
1 changed file
with
1 additions
and
2 deletions
... | ... | @@ -576,7 +576,7 @@ public class DefaultTransportService implements TransportService { |
576 | 576 | @Override |
577 | 577 | public void process(TransportProtos.SessionInfoProto sessionInfo, TransportProtos.PostEventMsg msg, |
578 | 578 | TransportServiceCallback<Void> callback,String topicName) { |
579 | - //Topic地址:v1/devices/event/${deviceId}/${identifier}/{$eventType} | |
579 | + //Topic地址:v1/devices/event/${deviceId}/${identifier} | |
580 | 580 | String[] topicInfo = topicName.split(MqttTopics.BASE_DEVICE_EVENT_TOPIC + "/"); |
581 | 581 | if(null == topicInfo || topicInfo.length !=2){ |
582 | 582 | throw new TkDataValidationException(ErrorMessage.INVALID_TOPIC.getMessage()); |
... | ... | @@ -597,7 +597,6 @@ public class DefaultTransportService implements TransportService { |
597 | 597 | metaData.putValue("device_profile_id", deviceProfileId.toString()); |
598 | 598 | metaData.putValue("deviceId",eventInfo[0]); |
599 | 599 | metaData.putValue("event_identifier", eventInfo[1]); |
600 | - metaData.putValue("event_type",eventInfo[2]); | |
601 | 600 | sendToRuleEngine(tenantId, deviceId, customerId, sessionInfo, json, metaData, SessionMsgType.POST_EVENT_REQUEST, |
602 | 601 | new TransportTbQueueCallback(new ApiStatsProxyCallback<>(tenantId, customerId, msg.getKvList().size(), callback))); |
603 | 602 | } | ... | ... |