Подписаться на Tuya MQ - PullRequest
Новая
       22

Подписаться на Tuya MQ

0 голосов
/ 08 ноября 2018

Я пытаюсь подписаться на Tuya MQ Server.

Мне дали следующий пример кода на Java: 

package com.tuya.open.sdk.example;
import org.apache.pulsar.client.impl.TopicMessageIdImpl;
import com.tuya.open.sdk.mq.MqConsumer;

public class ConsumerExample {

public static void main(String[] args) throws Exception {
    String url = "pulsar+ssl://mqe.tuyacn.com:7285/";
    String accessId = "";
    String accessKey = "";

    MqConsumer mqConsumer = MqConsumer.build().serviceUrl(url).accessId(accessId).accessKey(accessKey)
            .maxRedeliverCount(3).messageListener(message -> {
                System.out.println("Message received:" + new String(message.getData()) + ",seq="
                        + message.getSequenceId() + ",time=" + message.getPublishTime() + ",consumed time="
                        + System.currentTimeMillis() + ",partition="
                        + ((TopicMessageIdImpl) message.getMessageId()).getTopicPartitionName());
            });
    mqConsumer.start();
    }
}

Может кто-нибудь дать мне какие-либо идеи о том, как сделать выше, в C #?

Кажется, он использует несколько пакетов / импортов. Кто-нибудь знает альтернативы .Net.

Любая помощь / указатели будут очень признательны.

...