On Tue, Mar 31, 2015 at 12:08 PM, wonderkind <kevin...@am.sony.com> wrote:
>
> Is your broker running pretty clean when you send messages through the
fabric of network of replicated master/slaves?
Yes, though I'm only running the examples/openwire/swissarmy
producer/consumer example using the defaults. On the 2nd
cluster I set up a consumer to read from the 1st cluster:
[amq-prod-2c swissarmy]$ ant consumer
'-Durl=failover://(tcp://amq-prod-1a:61616,tcp://amq-prod-1b:61616,tcp://amq-prod-1c:61616)'
And on the 1st cluster I run a producer pushing to the 2nd cluster:
[amq-prod-1c swissarmy]$ ant producer
'-Durl=failover://(tcp://amq-prod-2a:61616,tcp://amq-prod-2b:61616,tcp://amq-prod-2c:61616)'
producer:
[echo] Running producer against server at $url =
failover://(tcp://amq-prod-2a:61616,tcp://amq-prod-2b:61616,tcp://amq-prod-2c:61616)
for subject $subject = TEST.FOO
[java] Connecting to URL:
failover://(tcp://amq-prod-2a:61616,tcp://amq-prod-2b:61616,tcp://amq-prod-2c:61616)
(:)
[java] Publishing a Message with size 1000 to queue: TEST.FOO
[java] Using non-persistent messages
[java] Sleeping between publish 0 ms
[java] Running 1 parallel threads
[java] log4j:WARN No appenders could be found for logger
(org.apache.activemq.thread.TaskRunnerFactory).
[java] log4j:WARN Please initialize the log4j system properly.
[java] log4j:WARN See
http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
[java] [Thread-1] Sending message: 'Message: 0 sent at: Tue Mar 31
12:38:39 PDT 2015 ...'
...
[java] [Thread-1] Sending message: 'Message: 1999 sent at: Tue Mar 31
12:38:40 PDT 201...'
[java] [Thread-1] Done.
consumer:
[echo] Running consumer against server at $url =
failover://(tcp://amq-prod-1a:61616,tcp://amq-prod-1b:61616,tcp://amq-prod-1c:61616)
for subject $subject = TEST.FOO
[java] Connecting to URL:
failover://(tcp://amq-prod-1a:61616,tcp://amq-prod-1b:61616,tcp://amq-prod-1c:61616)
(:)
[java] Consuming queue: TEST.FOO
[java] Using a non-durable subscription
[java] Running 1 parallel threads
[java] log4j:WARN No appenders could be found for logger
(org.apache.activemq.thread.TaskRunnerFactory).
[java] log4j:WARN Please initialize the log4j system properly.
[java] log4j:WARN See
http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
[java] [Thread-1] We are about to wait until we consume: 2000
message(s) then we will shutdown
[java] [Thread-1] Received: 'Message: 0 sent at: Tue Mar 31 12:38:39
PDT 2015 ...' (length 1000)
...
[java] [Thread-1] Received: 'Message: 1999 sent at: Tue Mar 31
12:38:40 PDT 201...' (length 1000)
[java] [Thread-1] Closing connection
[java] All threads completed their work
The only log information I see in /var/log/activemq.log on either master are
details about the master/slave coordination and the establishment of the
network.
