Tag: mq

如何清除MassTransit队列？

我想在集成测试SetUp例程中删除队列中的所有消息，我该如何实现？ google / intellisense-bruteforce没有运气。 如果重要 – 我正在使用RabbitMq作为传输。

如何获取Websphere MQ连接状态以及如何重置连接：

1.）从.net客户端，如何测试客户端是否连接到服务器（即可以发送和接收）是的，我可以在try块内发送消息并捕获随后的exception，但我希望更优雅的解决方案。 2）如何打开，关闭和重新打开连接？ 在我尝试解决上面的问题1时，我发现如果我打开连接然后调用connection.Close（）我无法从连接工厂获得另一个连接（请参阅下面的代码片段）。 我收到错误消息XMSCC0008 我使用的是非常标准的vanilla MQ配置。 以下是我的客户端连接方式： ISession session = MQAccess.GetSession(MQAccess.Connection); IDestination destination = session.CreateTopic(SubTopicName); Consumer = MQAccess.GetConsumer(session, destination); Consumer.MessageListener = new MessageListener(HandleMQSubEvent); MQAccess.Connection.Start(); 其中MQAccess是一个小实用程序类。 编辑了添加MQAccess代码的问题： public static class MQAccess { public static readonly MQConfigurationSectionHandler ConfigSettings; public static readonly IConnectionFactory ConnectionFactory; private static readonly IConnection connection; public static IConnection Connection { get { return connection; […]