Test mirror between a main and replica brokers with default options but queue-creation="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
an a queue:
ensure there is no queue or messages create 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 |
|DRSitec874c011-c032-45d0-abf2-9ccdd122c7e8|DRSitec874c011-c032-45d0-abf2-9ccdd122c7e8|1 |0 |2014 |0 |2014 |0 |ANYCAST |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|activemq.management.99c57948-8f04-49c0-a68e-8cd62e618235|activemq.management.99c57948-8f04-49c0-a68e-8cd62e618235|1 |0 |0 |0 |0 |0 |MULTICAST |
ensure there is no queue or messages create on replica broker but the queue 'queues.A' exists
$ 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 |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|activemq.management.443288e8-b480-4426-9474-9f1ad8fe24b4|activemq.management.443288e8-b480-4426-9474-9f1ad8fe24b4|1 |0 |0 |0 |0 |0 |MULTICAST |
|queues.A |queues.A |0 |0 |0 |0 |0 |0 |ANYCAST |
produce messages for queues.A on main broker:
$ main/bin/artemis producer --url tcp://10.0.132.32:61616 --destination queue://queues.A
Connection brokerURL = tcp://10.0.132.32:61616
Producer ActiveMQQueue[queues.A], thread=0 Started to calculate elapsed time ...
Producer ActiveMQQueue[queues.A], thread=0 Produced: 1000 messages
Producer ActiveMQQueue[queues.A], thread=0 Elapsed time in second : 2 s
Producer ActiveMQQueue[queues.A], thread=0 Elapsed time in milli second : 2327 milli seconds
ensure messages are on queues.A 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 |
|DRSitec874c011-c032-45d0-abf2-9ccdd122c7e8|DRSitec874c011-c032-45d0-abf2-9ccdd122c7e8|1 |0 |3022 |0 |3022 |0 |ANYCAST |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|activemq.management.1ac12cc6-681d-4588-bf42-1f124b12bf21|activemq.management.1ac12cc6-681d-4588-bf42-1f124b12bf21|1 |0 |0 |0 |0 |0 |MULTICAST |
|queues.A |queues.A |0 |1000 |1000 |0 |0 |0 |ANYCAST |
ensure messages are replicated to replica:
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 |
|ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST |
|activemq.management.e4c2ccb0-2241-45bb-b064-c0d310e38b29|activemq.management.e4c2ccb0-2241-45bb-b064-c0d310e38b29|1 |0 |0 |0 |0 |0 |MULTICAST |
|queues.A |queues.A |0 |1000 |1000 |0 |0 |0 |ANYCAST |