Test mirror between a main and replica brokers with default options but message-acknowledgements=false
Main:
created a broker with command:
$ amq-broker-7.8.0/bin/artemis create main --user admin --password admin --allow-anonymous
added to the config:
Replica:
created a broker with command:
$ artemis create --user admin --password admin --allow-anonymous ~/replica
added to the config:
an acceptor:
tcp://0.0.0.0:6700?autoStart=true;tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpMinLargeMessageSize=102400;amqpDuplicateDetection=true
produce messages on TEST.Q3 on main broker:
$ main/bin/artemis producer --url tcp://10.0.132.32:61616 --destination queue://TEST.Q3
Connection brokerURL = tcp://10.0.132.32:61616
Producer ActiveMQQueue[TEST.Q3], thread=0 Started to calculate elapsed time ...
Producer ActiveMQQueue[TEST.Q3], thread=0 Produced: 1000 messages
Producer ActiveMQQueue[TEST.Q3], thread=0 Elapsed time in second : 3 s
Producer ActiveMQQueue[TEST.Q3], thread=0 Elapsed time in milli second : 3252 milli seconds
ensure messages are on TEST.Q3 queue on main broker:
$ main/bin/artemis queue stat --url tcp://10.0.132.32:61616
Connection brokerURL = tcp://10.0.132.32:61616
|NAME |ADDRESS |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED |SCHEDULED_COUNT |ROUTING_TYPE |
|DLQ |DLQ |0 |0 |0 |0 |0 |0 |ANYCAST |
|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|1 |0 |1020 |0 |1020 |0 |ANYCAST |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|MY.MIRROR.Q |MY.MIRROR.Q |0 |0 |0 |0 |0 |0 |ANYCAST |
|TEST.Q3 |TEST.Q3 |0 |1000 |1000 |0 |0 |0 |ANYCAST |
|activemq.management.001201b8-416c-4a4e-acdd-26733bf2945f|activemq.management.001201b8-416c-4a4e-acdd-26733bf2945f|1 |0 |0 |0 |0 |0 |MULTICAST |
ensure messages are replicated to replica broker:
$ main/bin/artemis queue stat --url tcp://10.0.134.16:61616
Connection brokerURL = tcp://10.0.134.16:61616
|NAME |ADDRESS |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED |SCHEDULED_COUNT |ROUTING_TYPE |
|DLQ |DLQ |0 |0 |0 |0 |0 |0 |ANYCAST |
|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|0 |0 |0 |0 |0 |0 |ANYCAST |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|MY.MIRROR.Q |MY.MIRROR.Q |0 |0 |0 |0 |0 |0 |ANYCAST |
|TEST.Q3 |TEST.Q3 |0 |1000 |1000 |0 |0 |0 |ANYCAST |
|activemq.management.410156a7-81aa-455f-b97d-2f9e6747c452|activemq.management.410156a7-81aa-455f-b97d-2f9e6747c452|1 |0 |0 |0 |0 |0 |MULTICAST |
consume 100 messages from TEST.Q3 on main broker:
$ main/bin/artemis consumer --url tcp://10.0.132.32:61616 --destination queue://TEST.Q3 --message-count 100
Connection brokerURL = tcp://10.0.132.32:61616
Consumer:: filter = null
Consumer ActiveMQQueue[TEST.Q3], thread=0 wait until 100 messages are consumed
Consumer ActiveMQQueue[TEST.Q3], thread=0 Consumed: 100 messages
Consumer ActiveMQQueue[TEST.Q3], thread=0 Elapsed time in second : 0 s
Consumer ActiveMQQueue[TEST.Q3], thread=0 Elapsed time in milli second : 39 milli seconds
Consumer ActiveMQQueue[TEST.Q3], thread=0 Consumed: 100 messages
Consumer ActiveMQQueue[TEST.Q3], thread=0 Consumer thread finished
ensure 100 messages were consumed and has the MESSAGE_ACKED as 100 on main broker:
$ main/bin/artemis queue stat --url tcp://10.0.132.32:61616
Connection brokerURL = tcp://10.0.132.32:61616
|NAME |ADDRESS |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED |SCHEDULED_COUNT |ROUTING_TYPE |
|DLQ |DLQ |0 |0 |0 |0 |0 |0 |ANYCAST |
|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|1 |0 |1030 |0 |1030 |0 |ANYCAST |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|MY.MIRROR.Q |MY.MIRROR.Q |0 |0 |0 |0 |0 |0 |ANYCAST |
|TEST.Q3 |TEST.Q3 |0 |900 |1000 |0 |100 |0 |ANYCAST |
|activemq.management.0a4775b2-0e57-4f17-9af9-86331f6c12e7|activemq.management.0a4775b2-0e57-4f17-9af9-86331f6c12e7|1 |0 |0 |0 |0 |0 |MULTICAST |
ensure there still 1000 messages on replica broker with 0 MESSAGES_ACKED:
$ main/bin/artemis queue stat --url tcp://10.0.134.16:61616
Connection brokerURL = tcp://10.0.134.16:61616
|NAME |ADDRESS |CONSUMER_COUNT |MESSAGE_COUNT |MESSAGES_ADDED |DELIVERING_COUNT |MESSAGES_ACKED |SCHEDULED_COUNT |ROUTING_TYPE |
|DLQ |DLQ |0 |0 |0 |0 |0 |0 |ANYCAST |
|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|DRSitecd3e76cc-a194-44f3-b3b3-0efe8afef671|0 |0 |0 |0 |0 |0 |ANYCAST |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|MY.MIRROR.Q |MY.MIRROR.Q |0 |0 |0 |0 |0 |0 |ANYCAST |
|TEST.Q3 |TEST.Q3 |0 |1000 |1000 |0 |0 |0 |ANYCAST |
|activemq.management.6491f249-0803-4f47-9b38-7de822afad63|activemq.management.6491f249-0803-4f47-9b38-7de822afad63|1 |0 |0 |0 |0 |0 |MULTICAST |