Activemq cpp BytesMessage

Question

我正在使用activemq-cpp，并且我正在尝试使用BytesMessage发送二进制数据。我设置了一个生产者和一个消费者来发送和接收消息。连接和会话工作正常，因为我能够发布到主题，并允许使用者使用TextMessage拾取消息。在验证了连接性之后，我已经将我的TextMessage实现更改为BytesMessage。我现在遇到的问题是对BytesMessages进行代码转换，并在收到消息后从消息中提取数据。

在我的制片人中，我有：

    void producer() {
        try {
                //....setup code

                //temporary vector
                vector<unsigned char> vec;
                unsigned char temp1 = 'a';
                vec.push_back(temp1);
                vec.push_back(temp1);
                vec.push_back(temp1);

                BytesMessage * message = session->createBytesMessage();
                message->writeBytes(vec);
                cout << "SIZE IS: " << vec.size() << endl;
                producer->send( message );

                delete message;

            } catch (CMSException& e) {
                e.printStackTrace();
            }

} 

在我的消费者中，我有：

void begin(){
    // setup code to get session, etc.

    shared_ptr<BytesMessage> bytemessage =
            boost::dynamic_pointer_cast<BytesMessage>(message);

    vector<unsigned char> temp;
    bytemessage->readBytes(temp);

    cout << "SIZE IS: " << temp.size() << endl;
}

生产者打印出的尺寸是3，这是正确的。但是消费者打印出的大小为0，这表明它没有读入之前正确写入的消息。这让我不禁要问，我到底做错了什么？

我已经尝试在本地写入和读取它，但我仍然无法做到：

    void producer() {
        try {
                //....setup code

                //temporary vector
                vector<unsigned char> vec;
                unsigned char temp1 = 'a';
                vec.push_back(temp1);
                vec.push_back(temp1);
                vec.push_back(temp1);

                BytesMessage * message = session->createBytesMessage();
                message->writeBytes(vec);
                cout << "SIZE IS: " << vec.size() << endl;

                message->reset();

                vector<unsigned char> temp2;
                message->readBytes(temp2);

                cout << "SIZE IS2: " << temp2.size() << endl;

                delete message;

            } catch (CMSException& e) {
                e.printStackTrace();
            }

} 

写入之后的cout打印3，但读取之后的cout仍然打印0。

我没有正确地写入数据吗？任何在正确方向上的观点都是非常值得赞赏的。谢谢!

Answer 1

你有没有读过cms::BytesMessage的API文档，里面总结得很好。基本上，您需要在向量中分配您希望它填充的空间量。由于向量的大小不是返回任何值，因此可以使用BytesMessage的getBodyLength方法创建向量。

接口文档位于here。

-Tim www.fusesource.com