отправить сообщение из Java-программы в ActiveMQ, используя мул - PullRequest
Новая
       26

отправить сообщение из Java-программы в ActiveMQ, используя мул

0 голосов
/ 28 марта 2011

Я пытаюсь отправить строковое сообщение из Java-программы в очередь в ActiveMQ, используя MULE. Я новичок в муле, это мой mule-config.xml 

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns="http://www.mulesoft.org/schema/mule/core"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xmlns:jms="http://www.mulesoft.org/schema/mule/jms"
      xsi:schemaLocation="
      http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
      http://www.springframework.org/schema/tool http://www.springframework.org/schema/tool/spring-tool-3.0.xsd
      http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/3.1/mule-jms.xsd
      http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/3.1/mule.xsd">


<jms:activemq-connector name="jmsConnector" 
    specification="1.1" 
    brokerURL="tcp://localhost:61616" />
<model name="jmsModel">
    <service name="jmsService">
        <inbound>

        </inbound>
        <outbound>
            <pass-through-router>
                <jms:outbound-endpoint queue="myQueue" />
            </pass-through-router>
        </outbound>
    </service>
</model>
</mule>

и следующий мой класс Java 

public class MuleCaller {

    public static void main(String args[])
    {

        MuleCaller springCaller = new MuleCaller();
        springCaller.runListner();
        //  spAsync.onMessage(null);
}
public void runListner(){

    ClassPathXmlApplicationContext appContext = new ClassPathXmlApplicationContext(new String[] {
            "mule-config.xml"
        });

    }

В чем здесь ошибки, и мне непонятно, что писать в

Спасибо и всего наилучшего

Ответы [ 2 ]

3 голосов
/ 09 июля 2013

Это основано на более старой версии Mule (3.1.2) и использует синтаксис потока 

<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns="http://www.mulesoft.org/schema/mule/core"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jms="http://www.mulesoft.org/schema/mule/jms"
xsi:schemaLocation="
    http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/3.1/mule.xsd
    http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/3.1/mule-jms.xsd">

<jms:activemq-connector name="jmsConnector"  
    brokerURL="tcp://localhost:61616"
    specification="1.1"
    maxRedelivery="30"
    disableTemporaryReplyToDestinations="true"
    createMultipleTransactedReceivers="true"
    acknowledgementMode="CLIENT_ACKNOWLEDGE"
    numberOfConcurrentTransactedReceivers="1"
    persistentDelivery="true">
</jms:activemq-connector>

<flow name="inbound JMS service">
    <jms:inbound-endpoint connector-ref="jmsConnector" queue="/jmsQueue" exchange-pattern="one-way">
        <jms:transaction action="BEGIN_OR_JOIN"/>
    </jms:inbound-endpoint>

    <echo-component/>
</flow>

Используя консоль ActiveMQ, вы можете создать очередь с именем jmsQueue и вручную отправлять ей сообщения. Процесс Mule, использующий приведенную выше конфигурацию, должен распечатать любой текст в сообщении, которое вы помещаете в очередь.

1 голос
/ 20 апреля 2011

Во-первых, есть атрибут connector-ref тега jms: outbound-endpoint, который вы, вероятно, должны использовать для указания места, куда должны отправляться исходящие сообщения. как это: 

<jms:outbound-endpoint connector-ref="jmsConnection" queue="myQueue" />

Во-вторых, без входящего маршрута я понятия не имею, какие данные будут обрабатываться вашим сервисом. попробуйте еще один пример.

...