Hi,
Can you please post your message into the Activemq forum as this question is
not relevant for camel
remar k : Check using ant script of activemq (that you will find in the
example directory) that you can produce messages on one br1 and consume them
on another broker br2.
Regards,
Charles
On Wed, Sep 8, 2010 at 2:25 PM, Naira & Kobo <lekkie.ay...@gmail.com> wrote:
>
> 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&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&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-tp2807781p2807781.html
> Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
>
