Как соединить JMS-очереди из JBOSS 4 и 5? - PullRequest
Новая
       99

Как соединить JMS-очереди из JBOSS 4 и 5?

3 голосов
/ 31 августа 2010

У меня есть сервер, на котором работает Jboss 4.2.2 и Jboss 5.1.0.Проблема заключается в том, что сторонняя организация не может обновить свое приложение до Jboss 5.1.0 в ближайшем будущем, для нас это простой вопрос.К сожалению, нам нужно отправлять и получать некоторые сообщения JMS из стороннего приложения, работающего на Jboss 4.2.2.

Какой самый простой способ включить передачу сообщений JMS между JbossMQ и JbossMessaging?

1 Ответ

4 голосов
/ 06 сентября 2010

Я думаю, что нашел решение для моей проблемы. В документации JBOSS есть глава для переноса сообщений между JBOSS Messaging и JBOSS MQ: http://www.redhat.com/docs/en-US/JBoss_Enterprise_Application_Platform/5.0.0.BETA/html/JBoss_Messaging_User_Guide/inst-mqmessagemigration.html

У меня есть 2 темы myTopicSend и myTopicReceive на моем JBOSS 4.2, и у меня есть 2 темы myTopicSend5 и myTopicReceive5 на JBOSS 5.1.

Я хотел соединить все сообщения от myTopicSend к myTopicReceive5 и от myTopicSend5 к MyTopicReceive.

Почему-то сначала конфигурация вообще не работала, но после некоторого времени эксперимента у меня теперь есть следующий конфиг: 

<mbean code="org.jboss.jms.jndi.JMSProviderLoader"
       name="jboss.messaging:service=JMSProviderLoader,name=RemoteJBossMQProvider">
    <attribute name="ProviderName">RemoteXAConnectionFactory</attribute>
    <attribute name="ProviderAdapterClass">org.jboss.jms.jndi.JNDIProviderAdapter</attribute>
    <attribute name="FactoryRef">XAConnectionFactory</attribute>
    <attribute name="QueueFactoryRef">XAConnectionFactory</attribute>
    <attribute name="TopicFactoryRef">XAConnectionFactory</attribute>
    <attribute name="Properties">
        java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
        java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
        java.naming.provider.url=127.0.0.1:1099
    </attribute>
</mbean> 

<mbean code="org.jboss.jms.server.bridge.BridgeService"
       name="jboss.messaging:service=Bridge,name=LegayBridgeSend" xmbean-dd="xmdesc/Bridge-xmbean.xml">
    <depends optional-attribute-name="SourceProviderLoader">jboss.messaging:service=JMSProviderLoader,name=RemoteJBossMQProvider</depends>
    <depends optional-attribute-name="TargetProviderLoader">jboss.messaging:service=JMSProviderLoader,name=JMSProvider</depends>
    <attribute name="SourceDestinationLookup">/topic/myTopicSend</attribute>
    <attribute name="TargetDestinationLookup">/topic/myTopicReceive5</attribute>
    <attribute name="QualityOfServiceMode">0</attribute>
    <attribute name="MaxBatchSize">1</attribute>
    <attribute name="MaxBatchTime">-1</attribute>
    <attribute name="FailureRetryInterval">5000</attribute>
    <attribute name="MaxRetries">-1</attribute>
    <attribute name="AddMessageIDInHeader">false</attribute>
</mbean>

<mbean code="org.jboss.jms.server.bridge.BridgeService"
       name="jboss.messaging:service=Bridge,name=LegayBridgeReceive" xmbean-dd="xmdesc/Bridge-xmbean.xml">
    <depends optional-attribute-name="SourceProviderLoader">jboss.messaging:service=JMSProviderLoader,name=JMSProvider</depends>
    <depends optional-attribute-name="TargetProviderLoader">jboss.messaging:service=JMSProviderLoader,name=RemoteJBossMQProvider</depends>
    <attribute name="SourceDestinationLookup">/topic/myTopicSend5</attribute>
    <attribute name="TargetDestinationLookup">/topic/myTopicReceive</attribute>
    <attribute name="QualityOfServiceMode">0</attribute>
    <attribute name="MaxBatchSize">1</attribute>
    <attribute name="MaxBatchTime">-1</attribute>
    <attribute name="FailureRetryInterval">5000</attribute>
    <attribute name="MaxRetries">-1</attribute>
    <attribute name="AddMessageIDInHeader">false</attribute>
</mbean>

Я понял одну важную вещь: настроить параметры MaxBatchSize и MaxBatchTime , поскольку я хочу немедленно доставлять сообщения в целевую очередь.

Описание этих параметров можно найти по адресу http://www.redhat.com/docs/en-US/JBoss_Enterprise_Application_Platform/5.0.0/html/JBoss_Messaging_1.4.6/index.html

...