0

ObjectMessage インスタンスに整数メッセージを生成する Java ActiveMQ プロデューサーがあります。

Python 側では、キューでリッスンするために stomp python を使用します。ただし、すべてのヘッダーが正しく受信されているにもかかわらず、空のメッセージ本文を受信します。

さらに、Java側でメッセージタイプをTextMessageに変更すると、python-consumer側で正しいメッセージが得られます。

PyactiveMQ でも試しましたが、同じ効果がありました

任意の提案をいただければ幸いです!!!

編集：これは、Pythonでストンプをテストするために書いたボイラープレートのJavaプロデューサーコードとPythonサブスクライバーコードです

public class App 
{
Connection conn;
Session session;
MessageProducer producer;

public void registerPublisher(String queueName, String url) throws JMSException {
    ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("system", "manager" ,url);
    conn = cf.createConnection();
    conn.start();
    session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Destination destination = session.createQueue(queueName);
    producer = session.createProducer(destination);
    producer.setDeliveryMode(DeliveryMode.PERSISTENT);

}

public void send(int c) {

    for (int i=0; i<c; ++i) {

        try {
            TextMessage tm = session.createTextMessage(new Integer(i).toString());
//              ObjectMessage tm = session.createObjectMessage();
            producer.send(tm);
        } catch (JMSException e) {
            e.printStackTrace();
        }

    }
}

public static void main(String []arg) {
    App app = new App();
    try {
        app.registerPublisher(arg[0], arg[1]);
        System.out.println(app.session);
    } catch (JMSException e) {
        e.printStackTrace();
    }
    app.send(1000);
}


}

および Python Stomp リスナー

import time
import sys
import logging
import stomp
from stomp import ConnectionListener

queuename = sys.argv[1]

logging.basicConfig( level=logging.DEBUG)

class MyListener(ConnectionListener):
    def on_error(self, headers, message):
        print 'received an error %s' % message

    def onMessage(self, headers, message):
        print headers
        print str(message)
        print type(message)
        print 'received a message ...%s...' % message


conn = stomp.Connection([('localhost', 61613)])                                                                                               
conn.set_listener('', MyListener())
conn.start()
conn.connect()


conn.subscribe(destination='/queue/'+queuename, ack='auto')


while 1:
    time.sleep(2)
4

2 に答える 2

4

Stomp を介して受信 ObjectMessage タイプを送信するには、ActiveMQ のメッセージ変換機能を使用して、STOMP クライアントが理解できる形式でオブジェクト ペイロードを配信する必要があります。ActiveMQ はすぐに使用できる XML および JSON 変換サポートを提供しますが、独自のトランスフォーマーを追加して、コンテンツに必要な形式を取得できます。

于 2012-08-07T10:20:52.450 に答える
2

問題: ObjectMessage を Java プロデューサから ActiveMQ Broker に送信します。Stomp Python コンシューマー クライアントが空のメッセージ本文を取得していた

解決策 : Python クライアントで activemq ブローカーにサブスクライブするときに、変換ヘッダーを使用します。

例えば：

connection.subscribe(destination='/queue/'+queuename, ack='auto', transformation="jms-json")

ブローカがメッセージがどの形式でストンプクライアントに送信されるかを知るように

于 2012-08-08T11:18:59.170 に答える