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”搜索队列中的Message，其值为变量MsgID。如果未找到消息，则消费者等待新消息。

如果要搜索默认消息字段，则消息头字段引用仅限于JMSDeliveryMode，JMSPriority，JMSMessageID，JMSTimestamp，JMSCorrelationID和JMSType。 JMSMessageID，JMSCorrelationID和JMSType值可以为null，如果是，则将其视为NULL值。

Source Message Selectors

Answer 2

我使用Apache.NMS和Apache.NMS.ActiveMQ（1.7.1.3924）是否可以使用这个api而不是jms？我从1周开始尝试这个，而选择器也不起作用....也许是其他人