问题描述
我正在使用Google PubSub消息传递服务来提取已发布的消息,并使用此处的代码示例(https://cloud.google.com/pubsub/docs/quickstart-client-libraries#receive_messages):
SubscriptionName subscriptionName = SubscriptionName.FromProjectSubscription(projectId,subscriptionId);
SubscriberClient subscriber = await SubscriberClient.CreateAsync(subscriptionName);
Task startTask = subscriber.StartAsync((PubsubMessage message,CancellationToken cancel) =>
{
//Do something
return Task.FromResult(SubscriberClient.Reply.Ack);
});
我的问题是-是否可以某种方式获得连接已断开的通知?现在,如果我断开互联网连接,然后再次重新连接,我的应用程序将停止接收消息。如果在这种情况下发生某种异常,那将是很好的。有关如何解决此问题的任何想法将受到高度赞赏。
解决方法
StartAsync返回的任务将在发生不可恢复的错误(docs)时完成。如果您的订户长时间保持断开连接,我希望任务能够通知您。