Problem with consumer.receive MessageSelector

Question

我在activemq中遇到了问题。我想从我的 activemq 队列接收一条特殊消息。我有 300 多条消息，我想要其中一条消息。我用多选组合框解决了这个问题。在此框中，我拥有所有消息以及我需要的所有属性。

当我单击247项目时，我想选择接收消息的项目，在他们之后我想发送消息，但首先我在接收时遇到问题。

我不知道为什么它不起作用。也许有人有想法？

ErrorMessageProperty prop = new ErrorMessageProperty();
IMessage message = null;
try
{
    string MsgID = MSGID;
    string desinationque = sourceQueue;
    string selector = "ProducerId = '" + MsgID + "'";
    IDestination dest = MQSession.GetDestination(desinationque);
    Uri _activeMQURI = new Uri(conf.ActiveMqURL);
    MQConnectionFactory = new NMSConnectionFactory(_activeMQURI);
    using (MQConnection = MQConnectionFactory.CreateConnection(conf.ActiveMqUser, conf.ActiveMqPWD))
    using (MQSession = MQConnection.CreateSession(AcknowledgementMode.AutoAcknowledge))
    {
        try
        {
            MQConnection.Start();
        }
        catch (Exception ex)
        {
            myLogger.NLogger.Info("MQReceiveTextMessage Connection fehlgeschlagen: " + ex.Message);
        }
        using (IMessageConsumer consumer = this.MQSession.CreateConsumer(dest, selector,false))
        {
            if (shallwait)
            {
                try
                {
                    message = consumer.Receive();
                }
                catch (Exception ex)
                {
                    myLogger.NLogger.Error("Error in consumer Receive (MQReceiveTextMessage): Message" + message + " Fehler-Exception: " + ex.Message);
                }
            }
            else
            {
                message = consumer.Receive(TimeSpan.FromSeconds(1));
            }
        }
    }
}
catch (Exception ex)
{
    myLogger.NLogger.Error("Error in MQReceiveTextMessage: Parameter: sourceQueue: " + sourceQueue + " MSGID: " + MSGID + " Message: " + message + " Fehler-Exception: " + ex.Message);
}
return message;
}

我ProducerID是正确的。但是为什么这不起作用呢？它停在线路上

message = consumer.receive();

我不知道了

Answer 1

使用选择器 ProducerId = 'MsgIDValue' ，操作consumer.receive()在队列中搜索具有自定义属性"ProducerId"的消息，其值为变量 MsgID。如果未找到消息，则使用者将等待新消息。

如果要搜索默认消息字段，则消息头字段引用仅限于 JMSDeliveryMode、JMSPriority、JMSMessageID、JMSTimestamp、JMSCorrelationID 和 JMSType。JMSMessageID、JMSCorrelationID 和 JMSType 值可能为空，如果是，则被视为空值。

源消息选择器

Answer 2

我使用了Apache.NMS

和Apache.NMS.ActiveMQ(1.7.1.3924(您是否可以比JMS使用此API？我从 1 周开始尝试这个，但选择器不起作用......也许有人欠