Network of Brokers, Consumers not getting messages from queue

[Naira & Kobo]

Hi,

I have followed the article on activemq website on how to set up network of
brokers.

My brokers are able to talk to themselves using the
DiscoveryNetworkConnector. 
Below is the output of my activemq log:

Network connection between vm://default#16 and
tcp:///broker2ip:61616(default) has been established.

However, I cant receive messages send from borker1 (tcp://localhost:61616)
to broker2ip (which the consumer is conencted).

Why is that?

Here is my producer client config
        <bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
                <property name="alwaysSessionAsync" value="false"/>
                <property name="alwaysSyncSend" value="true"/>
                <property 
name="brokerURL"><value>${local-broker-url}</value></property>
                <property name="clientID" value=""/>
                <property name="closeTimeout" value="15000"/>
                <property name="copyMessageOnSend" value="true"/>
                <property name="disableTimeStampsByDefault" value="false"/>
                <property name="dispatchAsync" value="false"/>
                <property name="objectMessageSerializationDefered" 
value="false"/>
                <property name="optimizeAcknowledge" value="false"/>
                <property name="optimizedMessageDispatch" value="true"/>
                <property name="password" value=""/>
                <property name="producerWindowSize" value="0"/>
                <property name="statsEnabled" value="false"/>
                <property name="useAsyncSend" value="false"/>
                <property name="useCompression" value="false"/>
                <property name="useRetroactiveConsumer" value="false"/>
                <property name="userName" value=""/>
                <property name="watchTopicAdvisories" value="true"/>
                <property name="sendTimeout" value="0"/>
        </bean>
        
        <bean id="jmsConfig"
class="org.apache.camel.component.jms.JmsConfiguration">
            <property name="connectionFactory" ref="jmsConnectionFactory"/>
                <property name="concurrentConsumers"
value="${jms-concurrent-consumers}"/>
            <property name="requestTimeout" value="${jms-request-timeout}"/>
            <property name="timeToLive" value="${jms-request-timeout}"/>
                <property name="deliveryPersistent" value="true"/>
                <property name="explicitQosEnabled" value="true"/>              
                <property name="priority" value="${jms-message-priority}"/>
                <property name="acceptMessagesWhileStopping" value="false"/>    
        </bean>
        
        <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
                <property name="configuration" ref="jmsConfig"/>                
        </bean>

and this is how I create my endpoint in camelcontext
<endpoint id="jmsEndpoint"
uri="jms:queue:${queue}?exchangePattern=InOut&amp;replyTo=queue:${queue}Response"/>


and here is my consumer client config
        <bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
                <property name="alwaysSessionAsync" value="false"/>
                <property name="alwaysSyncSend" value="true"/>
                <property 
name="brokerURL"><value>${local-broker-url}</value></property>
                <property name="clientID" value=""/>
                <property name="closeTimeout" value="15000"/>
                <property name="copyMessageOnSend" value="true"/>
                <property name="disableTimeStampsByDefault" value="false"/>
                <property name="dispatchAsync" value="false"/>
                <property name="objectMessageSerializationDefered" 
value="false"/>
                <property name="optimizeAcknowledge" value="false"/>
                <property name="optimizedMessageDispatch" value="true"/>
                <property name="password" value=""/>
                <property name="producerWindowSize" value="0"/>
                <property name="statsEnabled" value="false"/>
                <property name="useAsyncSend" value="false"/>
                <property name="useCompression" value="false"/>
                <property name="useRetroactiveConsumer" value="false"/>
                <property name="userName" value=""/>
                <property name="watchTopicAdvisories" value="true"/>
                <property name="sendTimeout" value="0"/>
        </bean>
        
        <bean id="jmsConfig"
class="org.apache.camel.component.jms.JmsConfiguration">
            <property name="connectionFactory" ref="jmsConnectionFactory"/>
                <property name="concurrentConsumers"
value="${jms-concurrent-consumers}"/>
            <property name="requestTimeout" value="${jms-request-timeout}"/>
            <property name="timeToLive" value="${jms-request-timeout}"/>
                <property name="deliveryPersistent" value="true"/>
                <property name="explicitQosEnabled" value="true"/>              
                <property name="priority" value="${jms-message-priority}"/>
                <property name="acceptMessagesWhileStopping" value="false"/>    
        </bean>
        
        <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
                <property name="configuration" ref="jmsConfig"/>                
        </bean>

and this is how I create my endpoint in camelcontext
<endpoint id="jmsEndpoint"
uri="jms:queue:${queue}?exchangePattern=InOut&amp;replyTo=queue:${queue}Response"/>

Regards.

-- 
View this message in context: 
http://camel.465427.n5.nabble.com/Network-of-Brokers-Consumers-not-getting-messages-from-queue-tp2806330p2806330.html
Sent from the Camel - Users mailing list archive at Nabble.com.