带有 .NET Core 3.1 的 IBM MQ XMS - 如何获取主题上已经存在的消息？

Question

我正在尝试从我的 .NET Core 辅助角色服务中使用来自 WMQ 的消息。如果我启动我的服务然后在队列上发布消息，我就会让它工作，但我的服务会忽略所有已经存在的消息。我读到了有关持久订阅者的信息，但这似乎并不是我所追求的。

当前使用 nuget：IBMXMSDotnetClient，9.2.0.1

代码：

var destinationName = _apexConsumerOptions.Destination;

var isTopic = destinationName.StartsWith("topic://");

destinationName = destinationName.Remove(0, 8);

_connectionWmq = CreateConnection();

_sessionWmq = _connectionWmq.CreateSession(false, AcknowledgeMode.ClientAcknowledge);

_destination = isTopic ? _sessionWmq.CreateTopic(destinationName) : _sessionWmq.CreateQueue(destinationName);

_consumer = _sessionWmq.CreateConsumer(_destination);

_connectionWmq.Start();

while (!stoppingToken.IsCancellationRequested)
{
    //  fetch message
    var message = _consumer.Receive(_apexConsumerOptions.Timeout);

    HandleMessage(message);
    await Task.Delay(_apexConsumerOptions.MillisecondsBetweenSyncPolls, stoppingToken);
}
_connectionWmq.Close();

我正在尝试订阅主题，而不是队列。

我也有 MessageListener 仅在发布第一条消息时激活的问题，但这似乎是 9.2 的已知问题。

Answer 1

最终它是我想要的持久订阅者，所以实现它解决了我的问题。

link 到文档 @ibm 关于持久订户：https://www.ibm.com/support/knowledgecenter/SSFKSJ_9.2.0/com.ibm.mq.dev.doc/xms_csub_dur.htm

带有 .NET Core 3.1 的 IBM MQ XMS - 如何获取主题上已经存在的消息？

IBM MQ XMS with .NET Core 3.1 - how fetch messages already existing on topic?

c#

asp.net-core

.net-core

ibm-mq

xms