CamelのActiveMQ TCPトランスポートをJava（XMLではなく）を使用して公開する

Question

キャメルのActiveMQ TCPトランスポートがXMLを使用して公開されているものの、Javaを使用していない多くの例を見てきました。

誰でもこの方法を知っていますか？

どこにも例がないようです。

私はCamel、ActiveMQでSpring Bootを使用しています。

Answer 1

はい、JMS経由でJavaオブジェクトを送信できます。あなたが確認する必要があるのは、Javaオブジェクトがシリアライズ可能であることだけです。つまり、クラスはSerializableを実装する必要があります。その後、単にActiveMQにJavaオブジェクトを送受信してください。

<to uri="activemq:queueName"/> 

Answer 2

私は答えが見つかりました。

新しいBrokerServiceを作成する場合は

...

//whatever URI, broker name you want 
    String uri = "tcp://localhost:61617"; 
    String brokerName = "my-tcp-broker"; 

    BrokerService brokerService = new BrokerService(); 
    brokerService.setBrokerName(brokerName);  

    TransportConnector connector = new TransportConnector(); 
    connector.setUri(new URI(uri)); 
    brokerService.addConnector(connector); 
    brokerService.start(); 

または、既存のBrokerServiceを使用している場合...

BrokerService brokerService = BrokerRegistry.getInstance().lookup(brokerServiceName); 
    TransportConnector connector = new TransportConnector(); 
    connector.setUri(new URI(uri)); 
    connector.setBrokerService(brokerService); 
    brokerService.addConnector(connector); 
    connector.start();