ActiveMQ;ブローカに複数のtransportConnectors間でメッセージを配信させる方法

Question

ActiveMQブローカは、あるtransportConnectorで受信したメッセージを他のtransportConnectorsにも配布できるようにすることは可能ですか？ 具体的な使用例は次のとおりです。openwire transportConnectorを使ってメッセージを送信するJavaクライアントがあり、mqtt transportConnectorでそれらを読み取ることができます。私はそれが「VM」を使用して実行していなかったので、「TCPのいずれかで、デフォルトの「VM」transportConnectorを交換しなければならなかった

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory 

# use the following property to configure the default connector 
java.naming.provider.url = tcp://localhost:61616 

# use the following property to specify the JNDI name the connection factory 
# should appear as. 
#connectionFactoryNames = connectionFactory, queueConnectionFactory, topicConnectionFactry 

# register some queues in JNDI using the form 
# queue.[jndiName] = [physicalName] 
queue.MyQueue = example.MyQueue 

# register some topics in JNDI using the form 
# topic.[jndiName] = [physicalName] 
topic.MyTopic = example.MyTopic 

： 私はActiveMQのページhttp://activemq.apache.org/jndi-support.htmlにあるサンプルjndi.propertiesファイルを使用します。 メッセージはJava MessageListenerインスタンスにプッシュされますが、mqttクライアントには表示されません。私は 'example.MyTopic'から '/ example/MyTopic'まで、さまざまなトピックで試してみました。

ご協力いただければ幸いです。 多くのおかげで、

ローマ

Answer 1

ブローカーは、デフォルトでは、あなたが何が起こっているか確認するために与えられた目的地に登録生産者と消費者のための管理コンソールをチェックし、右の何かをやっていないので、ありません。送信された時点でオンラインになっていないか、または以前に永続的なトピックサブスクリプションを作成していない限り、トピックのコンシューマはそのトピックに送信されたメッセージを受信しません。