I was reading "ActiveMQ in Action" and got to the "PEER PROTOCOL" section in chapter 4. The "EXAMPLE USE OF THE PEER PROTOCOL" on page 93 reads /exactly /like the scenario I need to support. So I implemented a PeerGroup version of my test.
/I am having the exact same problem! All the connections are there, but no messages get passed./ I would think there's something wrong with my producer, but in the previous set of test classes, I can demonstrate that when the producer is connected directly to a remote stand-alone router (i.e. a running instance of activemq "out-of-the-box"), the messages get through to the consumer. It's only when my producer tries to publish via the embedded broker to another broker that messages don't make it out. There's got to be something simple I must be missing. Here's my code. The first few classes are there to make it a bit easier to write the core classes: IRunnable ------------------- ------------------- Utils ------------------- ------------------- Constants ------------------- ------------------- SubscribeTopicTest ------------------- ------------------- PublishTopicTest ------------------- ------------------- Here's the run log from the Publisher ------------------- ------------------- Here's the run log from the Subscriber ------------------- ------------------- -- View this message in context: http://activemq.2283324.n4.nabble.com/Persistent-messages-not-moving-from-embedded-broker-to-remote-broker-tp4702884p4702990.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
