Test sender and receiver with queue-name 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 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 add to the config the broker connection: 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 added to the config the broker connection: added to the config the addresses:
produce messages on TEST.Q3 $ 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 : 2 s Producer ActiveMQQueue[TEST.Q3], thread=0 Elapsed time in milli second : 2922 milli seconds Check the messages on queues in main and replica: $ 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 | |ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST | |TEST.Q3 |TEST.Q3 |2 |0 |1000 |0 |1000 |0 |ANYCAST | |activemq.management.fbcd6e7d-a028-4c7c-9043-254b7ccec5fc|activemq.management.fbcd6e7d-a028-4c7c-9043-254b7ccec5fc|1 |0 |0 |0 |0 |0 |MULTICAST | 2020-12-07 12:42:42 ⌚ tbueno-rhel8-1 in ~ $ 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 | |ExpiryQueue |ExpiryQueue |0 |0 |0 |0 |0 |0 |ANYCAST | |TEST.Q3 |TEST.Q3 |0 |1000 |1000 |0 |0 |0 |ANYCAST | |activemq.management.9a0dfe80-a3b8-4be2-8741-2feb92424f6b|activemq.management.9a0dfe80-a3b8-4be2-8741-2feb92424f6b|1 |0 |0 |0 |0 |0 |MULTICAST |