c# - 如何使用 Apache.NMS.ActiveMQ (C#) 向消息添加自定义属性？

Question

我从 C# 中的 ActiveMQ 开始。我将我的对象序列化为 json 并毫无问题地发送它。

我会在我的消息中添加属性，但我没有成功。我在少数网站上看到过 setIntProperty(String name,int value)，但在 Apache.NMS.ActiveMQ (C#) 上找不到。

这是我的代码：

ActiveMQ mom = new ActiveMQ();
ISession session = mom.Initialize();
IDestination dest = session.GetQueue(queueDestination);
using (IMessageProducer producer = session.CreateProducer(dest))
{
    foreach (Store s in stores)
    {
        List<string> matchKeyProductList = db.GetProductsKeyList(websiteNumberID);
        ArrayList arCodesProdToUpdate = db.GetProductsToUpdate(websiteNumberID);

        JavaScriptSerializer serializer = new System.Web.Script.Serialization.JavaScriptSerializer();
        serializer.MaxJsonLength = Int32.MaxValue; //Augmentation de la propriété MaxJsonLenth
        MessageObject message = new MessageObject(matchKeyProductList, arCodesProdToUpdate);
        string jsonMessage = serializer.Serialize(message);

        ITextMessage textMessage = producer.CreateTextMessage(jsonMessage);
        producer.Send(textMessage);
    }
}
mom.Cleanup();

任何人都可以帮我举个例子吗？

Answer 1

ITextMessage继承自IMessage，它有一个属性映射，有几个适用的设置方法。在发送之前，您应该能够如下设置：

ITextMessage textMessage = producer.CreateTextMessage(jsonMessage);
textMessage.Properties.SetInt("CustomInt", 1234);
textMessage.Properties.SetString("CustomString", "HelloWorld");
producer.Send(textMessage);