package queue type ClusterService interface { PushMessageToRuleEngine(info *TopicPartitionInfo, msgId string, msg []byte, callback Callback) }