2

azure servicebus/iothub のメッセージを常にチェックしたい。ただし、このようにすると、次のエラーが発生します

「タイプ 'Amqp.AmqpException' の例外が mscorlib.dll で発生しましたが、ユーザー コードで処理されませんでした追加情報: 操作 'Receive' は、状態: 終了では無効です。」

メッセージの絶え間ないプルを実装する方法や、このエラーを解決する方法はありますか?

var connection = new Connection(address);
var session = new Session(connection);
var entity = Fx.Format("/devices/{0}/messages/deviceBound", _deviceId);

var receiveLink = new ReceiverLink(session, "receive-link", entity);
while (true)
{
    await Task.Delay(1000);

    var message = await receiveLink.ReceiveAsync();
    if (message == null) continue;
    //else do things with message
 }
4

1 に答える 1