0


我正在使用 .NET 3.5 向活动 mq 发送消息，并且我有一个 java 侦听器来处理来自队列的这些消息。

标题包含

userId - long
type - string
isAdd-bool

侦听器期望有效负载的数据类型为 long。所以我应该在有效载荷中发送数据类型长。

这是我用来将消息发布到活动 mq 的代码。

string payLoad = "123";    
IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
                    using (IConnection connection = factory.CreateConnection())
                    {
                        using (ISession session = connection.CreateSession())
                        {
                            IDestination destination = Apache.NMS.Util.SessionUtil.GetDestination(session
                                , "Message.AddUser");
                            using (IMessageProducer producer = 

session.CreateProducer(destination))
                            {
                            // Start the connection so that messages will be processed.
                            connection.Start();

                            //here i need to pass payload as datatype "long"
                            ITextMessage request = session.CreateTextMessage(payLoad);
                            request.Properties["userid"] = 123;
                            request.Properties["type"] = "USER";
                            request.Properties["isAdd"] = true;
                            producer.Send(request);

                        }

                    }
                }

目前根据代码，我将字符串作为有效负载发送。

 ITextMessage request = session.CreateTextMessage(payLoad);

如何更改此代码以将有效负载作为数据类型长发送？我试图将有效负载作为对象发送。但是当听众选择这个消息时我得到一个错误。错误：无效的流标头已损坏。

根据评论，我使用了 IStreamMessage

            int userId = 123;
            IStreamMessage message = session.CreateStreamMessage()
            message.WriteInt64((long)idToUpdate);
            message.Properties.SetLong("userId", (long)userId);
            message.Properties.SetString("type", "USER");
            message.Properties.SetBool("isDelete", true);

然后我查看了tomcat日志，这就是我所看到的，其中缺少标题。我只有有效载荷

[Payload=ActiveMQStreamMessage {commandId = 5, responseRequired = true, messageId = ID:XXXXX-60790-
stamp=1400070001928, jms_redelivered=false, userId=123, type=USER, jms_messageId=ID:XXXXX-60790-635356865723233336-0:0:1:2:1}]

由于这不起作用，我尝试使用 ITextMessage。

int userId = 123;
ITextMessage request = session.CreateTextMessage();
request.Text = idToUpdate.ToString();
request.Properties["companyId"] = (long)userId;
request.Properties["type"] = "USER";
request.Properties["isDelete"] = true;

这是我在日志中可以看到的。

[Payload=46][Headers={timestamp=1400072608501, id=dde638d2-4036-4e81-a3c8-97937ac11087, isDelete=true, jms_timestamp=1400072608280, jms_redelivered=false, userId=1, type=USER, jms_messageId=ID:xxxx-53593-635356892076410652-0:0:1:2:1}]

我正在使用 Sprint 集成，并且侦听器期望 List 作为输入参数

public void updateUser(Message<List<Long>> message) {
    Long userId = (Long) message.getHeaders().get("userId");    
    for (Long userId : message.getPayLoad()) { // exception is thrown here "Caused by: java.lang.ClassCastException: java.lang.String cannot be cast to java.lang.Long"
        //doing somethign here with userid
    }
}

如何发送长数据类型的有效载荷？

4

2 回答 2

0

你有几个选择如何实现它。

  • 您可以使用 BytesMessage 并使用对 long 进行操作的读/写方法，但那里没有类型检查，因此请确保您的客户都做正确的事情。
  • 您可以使用具有长时间读取/写入功能的 StreamMessage，如果您愿意，它将检查类型并根据需要进行一些类型转换。
  • 您可以使用 MapMessage 并将 long 存储在键/值映射中。
  • 您可以使用标准 Java 代码将 TextMessage 的文本解析为 long。

您不能真正在 .NET 和 Java 之间使用 ObjectMessage，在这种情况下您也不想这样做，因为它是一个简单的原始类型。

于 2014-05-14T10:28:05.987 回答
0

您可以使用 ObjectMessage 代替 TextMessage。

看这里：

http://docs.oracle.com/javaee/6/api/javax/jms/ObjectMessage.html

于 2014-05-14T09:49:55.137 回答