我的理解是，当在生产者中指定AcknowledgementMode.ClientAcknowledge时，我应该能够停止和重新启动消费者，代理将重新发送关于该主题的所有未确认的消息。但是这个不行。（我也尝试过在消费者中使用onMessage侦听器，但我得到了相同的行为。）任何帮助都是感激的。这是我的制作人：

static void Main(string[] args) {
        IConnectionFactory factory = new NMSConnectionFactory("tcp://localhost:61616");
        using (IConnection connection = factory.CreateConnection()) {
            connection.ClientId = "producer";
            using (ISession session = connection.CreateSession(AcknowledgementMode.ClientAcknowledge)) {
                IDestination destination = SessionUtil.GetDestination(session, "MY_TOPIC", DestinationType.Topic);
                IMessageProducer producer = session.CreateProducer(destination);
                while (!Console.KeyAvailable) {
                    string message = "[" + DateTime.UtcNow.ToString("yyyy/MM/dd HH:mm:ss.fff") + "]";
                    ITextMessage xtext_message = session.CreateTextMessage(message);
                    producer.Send(xtext_message, MsgDeliveryMode.Persistent, MsgPriority.Normal, new TimeSpan(1, 0, 0));
                    Console.WriteLine("Sent message:" + message);
                    Thread.Sleep(1000);
                }
            }
        }
    }

这是我的消费者：

static void Main(string[] args) {
        IConnectionFactory factory = new NMSConnectionFactory("tcp://localhost:61616/");
        using (IConnection connection = factory.CreateConnection()) {
            connection.ClientId = "consumer";
            connection.Start();
            using (ISession session = connection.CreateSession()) {
                IMessageConsumer consumer = session.CreateConsumer(SessionUtil.GetDestination(session, "MY_TOPIC", DestinationType.Topic));
                while (!Console.KeyAvailable) {
                    ITextMessage receivedMsg = consumer.Receive() as ITextMessage;
                    if (receivedMsg != null) {
                        Console.WriteLine("--> received: " + receivedMsg.Text);
                    }
                }
            }
        }
    }