[jboss-user] [JBoss Messaging] - Re: Bridge - Foreign Message (ActiveMQ -> JbossMessaging)

[aslak]

  | <connection-factories>
  | 
  |   <mbean code="org.jboss.jms.jndi.JMSProviderLoader"
  |          name="jboss.mq:service=JMSProviderLoader,name=ActiveMQJMSProvider">
  |     <attribute name="ProviderName">ActiveMQJMSProvider</attribute>
  |     <attribute name="ProviderAdapterClass">
  |       org.jboss.jms.jndi.JNDIProviderAdapter
  |     </attribute>
  |     <!-- The combined connection factory -->
  |     <attribute name="FactoryRef">ConnectionFactory</attribute>
  |     <!-- The queue connection factory -->
  |     <attribute name="QueueFactoryRef">ConnectionFactory</attribute>
  |     <!-- The topic factory -->
  |     <attribute name="TopicFactoryRef">ConnectionFactory</attribute>
  |         <attribute name="Properties">
  |         java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory
  |         java.naming.provider.url=tcp://xx.xx.xx.xx:61616
  |         queue.inbound=OM.from
  |         queue.outbound=OM.to
  |         </attribute>
  | 
  |   </mbean>
  | </connection-factories>
  | 


  | 
  |    <mbean code="org.jboss.jms.server.bridge.BridgeService"
  |       name="com.nordpool:service=Bridge,name=BridgeFromOM"
  |       xmbean-dd="xmdesc/Bridge-xmbean.xml">
  | 
  |       <attribute name="SourceProviderLoader">jboss.mq:service=JMSProviderLoader,name=ActiveMQJMSProvider</attribute>
  | 
  |       <attribute name="TargetProviderLoader">jboss.messaging:service=JMSProviderLoader,name=JMSProvider</attribute>
  | 
  |       <attribute name="SourceDestinationLookup">inbound</attribute>
  | 
  |       <attribute name="TargetDestinationLookup">topic/npmq.in</attribute>
  | 
  |       <attribute name="SourceUsername">xx</attribute>
  | 
  |       <attribute name="SourcePassword">xx</attribute>
  | 
  |       <attribute name="TargetUsername">xx/attribute>
  | 
  |       <attribute name="TargetPassword">xx</attribute>
  | 
  |       <attribute name="QualityOfServiceMode">0</attribute>
  | 
  |       <attribute name="Selector"></attribute>
  | 
  |       <attribute name="MaxBatchSize">1</attribute>
  | 
  |       <attribute name="MaxBatchTime">1</attribute>
  | 
  |       <attribute name="SubName"></attribute>
  | 
  |       <attribute name="ClientID"></attribute>
  | 
  |       <attribute name="FailureRetryInterval">1000</attribute>
  | 
  |       <attribute name="MaxRetries">2</attribute>
  | 
  |    </mbean>
  | 


Messaging Bridge:
source -> ActiveMQ queue via ActiveMQJMSProvider configured to talk to the ActiveMQServer
target -> JbossTopic on JbossMessaging

1. The bridges source consumer receives a ActiveMQMessage from the ActiveMQProvider
2. The bridge tries to send the message to the target JbossProducer.
3. The JbossProducer figures out it is a foreign message and converts the message to a JbossMessage. The JbossProducers target JbossDestination is lost in the translation. (to be correct, the ActiveMQDestination is set on the JbossMessage and the ServerConnection failes casting it.)



View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4072507#4072507

Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4072507