activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: replicate messages
Date Fri, 19 Jan 2007 09:14:25 GMT
Please always include the full stack trace. More notes on how to get
better support here...
http://incubator.apache.org/activemq/support.html


On 1/17/07, devu <dyu@hatsize.com> wrote:
>
> Thanks for your help. In fact, I tried this config before I post, but it has
> such problem:
>
> Test case:
> Step:
> 1: prepare a client, create two queue with different topics, suppose TpcA,
> TpcB
> 2: send 10 messages for on each topic, suppose MsgA1 - A10  and MsgB1 - B10
> to jms1 only
> 3: start ConsumerA to connect jms1 to consume MsgA, it should receive the
> messages
>
> 4: delete all messages, restart the environment
> 5: run step 1,2
> 6: start ConsumerA to connect jms2 to consume MsgA, it should receive the
> messages
>
> 7: delete all messages, restart the environment
> 8: run step 1,2
> 9: start ConsumerB to connect jms1 to consume MsgB, it should receive the
> messsages
>
> 10: delete all messages, restart the environment
> 11: run step 1,2
> 12: start ConsumerB to connect jms2 to consume MsgB, it should receive the
> messages
>
> step 9 fail.
>
> Get exception:
>
> DemandForwardingBridge         - Network connection between vm://xxxxxx#0
> and tcp://172.16.1.x1:61616 shutdown due to a local error:
> java.lang.NullPointerException
>
>
>
>
> Marlon Santos wrote:
> >
> > Hi,
> >
> > It seems odd that your networkConnector config is connecting to itself. So
> > you use this config
> >
> > server1 config
> >
> > <networkConnector name="jms1" uri="static://(tcp://172.16.1.x2:61616)"
> > networkTTL="2" failover="true">
> >
> >
> > server2 config
> >
> >  <networkConnector name="jms2" uri="static://(tcp://172.16.1.x1:61616)"
> > networkTTL="2" failover="true"/>
> >
> > rather than the one you were using. The networkTTL specifies how many
> > brokers the messages and subscriptions can pass through. If it still
> > doesnt work, make the networkTTL value larger. More info
> > http://activemq.org/site/networks-of-brokers.html here , on network
> > connector properties.
> >
> > Regards,
> > Marlon
> >
> >
> > devu wrote:
> >>
> >> Hi, I have some problem to do it like this:
> >>
> >> I have two jms servers.
> >> producer A connect to jms1, consumer B connect jms1 to listen topic1,
> >> consumer C connect to jms2 topic2.
> >>
> >> Then producer start a session and two topics in different queues.
> >> However, consumer C could not receive topic2 from jms2. It has to connect
> >> to jms1 to receive them.
> >>
> >> I already config two jms servers like this:
> >>
> >>  <networkConnector name="jms1"
> >> uri="static://(tcp://172.16.1.x1:61616,tcp://172.16.1.x2:61616)"
> >> failover="true">
> >>
> >>  <networkConnector name="jms2"
> >> uri="static://(tcp://172.16.1.x1:61616,tcp://172.16.1.x2:61616)"
> >> failover="true"/>
> >>
> >> the ip address 172.16.1.x1 is the first jms ip address and 172.16.1.x2 is
> >> the second one.
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >
> >
>
> --
> View this message in context: http://www.nabble.com/replicate-messages-tf3022632.html#a8418595
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message