很难找到一些关于将所有消息放在deadletter队列中并查看它们的好文档。我有一个Azure服务总线队列。我能找到的所有东西都是针对服务总线的话题...有人可以通过快速指南帮助我吗?如何查看deadletter消息
0
A
回答
3
死信队列是一个次要子队列,其中毒讯息被移动到。 对于azure服务总线队列,DLQ的标准路径是queuePath/$ DeadLetterQueue。 所以你需要有另一个queueclient来读取这个DLQ。
而你会在.net客户端中做这样的事情。
string connectionString = CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString");
QueueClient Client = QueueClient.CreateFromConnectionString(connectionString, "QueueName");
// do whatever regular queue reading activities
// this is for dead letter queue
QueueClient deadLetterClient = QueueClient.CreateFromConnectionString(connectionString, QueueClient.FormatDeadLetterPath(Client.Path), ReceiveMode.ReceiveAndDelete);
BrokeredMessage receivedDeadLetterMessage;
while ((receivedDeadLetterMessage = deadLetterClient.Receive(TimeSpan.FromSeconds(10))) != null)
{
Console.WriteLine(receivedDeadLetterMessage);
}
0
string connectionString = ConfigurationManager.AppSettings["connectionString"];
string queueName = ConfigurationManager.AppSettings["queueName"];
ServiceBusConnectionStringBuilder builder = new ServiceBusConnectionStringBuilder(connectionString);
MessagingFactory factory = MessagingFactory.CreateFromConnectionString(builder.ToString());
var client = QueueClient.CreateFromConnectionString(connectionString, queueName);
string deadLetterQueuePath = QueueClient.FormatDeadLetterPath(queueName);
QueueClient deadletterQueueClient = factory.CreateQueueClient(deadLetterQueuePath);
while (true)
{
BrokeredMessage brokeredMessage = deadletterQueueClient.Receive();
// Your Logic
}
0
下面是如何在使用皮克死信队列得到的所有消息列表的例子:
public async Task<IEnumerable<BrokeredMessage>> GetDeadLetterMessagesAsync(string connectionString,
string queueName)
{
var queue = QueueClient.CreateFromConnectionString(connectionString, QueueClient.FormatDeadLetterPath(queueName));
var messageList = new List<BrokeredMessage>();
BrokeredMessage message;
do
{
message = await queue.PeekAsync();
if (message != null)
{
messageList.Add(message);
}
} while (message != null);
return messageList;
}
相关问题
- 1. 如何查看kafka消息
- 2. 如何在azureservicebus中查看并删除deadletter的邮件
- 3. 如何查看消息的语言ID?
- 4. Tidy.NET - 如何查看错误消息?
- 5. 如何在firefox中查看dump()消息?
- 6. 如何查看队列中的消息
- 7. 如何查看出站MSMQ消息队列中的消息?
- 8. 查看TeamCity服务消息
- 9. VB6查看消息队列
- 10. MVC通消息查看
- 11. ASP.NET MVC查看消息
- 12. Azure NodeJS函数和服务总线,DeadLetter消息
- 13. 当鼠标悬停在消息上时,如何查看实际消息?
- 14. 如果我没有收到DeadLetter消息,是否有可能发生ActorRef更改?
- 15. iOS邮件消息查看像UIWebView
- 16. 发送消息从控制器查看
- 17. 使用导轨查看预定消息
- 18. 电报频道消息查看次数
- 19. 查看消息,移动浏览器
- 20. MVVM ViewModel查看消息传送
- 21. 查看删除Facebook上的消息
- 22. ThunderBird查看消息的事件
- 23. 无法通过php查看消息?
- 24. 查看消息的事件API文本
- 25. 查看旧失败的提交消息
- 26. ActionResult需要发送消息来查看
- 27. 在Windows 8.1中查看DbgPrint消息
- 28. Zend的回送消息,以查看
- 29. codeigniter - 将消息传递给查看
- 30. 在VS2010中查看调试消息
但是我真的不知道该topicPath是什么?既然这是一个队列而不是话题? –
对不起。我用队列客户端更新了代码。出于某种原因,我认为你要求主题和潜艇。 – Aravind
嗯,当涉及到while循环这个给我以下错误: 型“System.UnauthorizedAccessException的”未处理的异常在Microsoft.ServiceBus.dll发生 附加信息:虽然授权令牌无效签名, 感谢:40103 ! –