[ARTEMIS-4017] FQQN Anycast Redistribution on a symmetric cluster is redistributing to different FQQN in the same address - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Reopened
Priority: Critical
Resolution: Unresolved
Affects Version/s: 2.25.0
Fix Version/s: None
Component/s: Broker
Labels:
None

Environment:

Hide

The current environment I'm working with is a Symmetric cluster of 2 master nodes, and I intend to add a slave node for each of the master.

The first master has the following configuration:

<?xml version="1.0" encoding="UTF-8" standalone="no"?>

<configuration xmlns="urn:activemq"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
    <core xmlns="urn:activemq:core">

        <name>master0</name>
        <persistence-enabled>true</persistence-enabled>

        <bindings-directory>data/bindings</bindings-directory>

        <journal-directory>data/journal</journal-directory>
        <journal-datasync>true</journal-datasync>
        <journal-min-files>2</journal-min-files>
        <journal-pool-files>10</journal-pool-files>
        <journal-device-block-size>4096</journal-device-block-size>
        <journal-file-size>10M</journal-file-size>

        <large-messages-directory>data/largemessages</large-messages-directory>

        <paging-directory>data/paging</paging-directory>


        <!-- Connectors -->

        <connectors>
            <connector name="master0">tcp://xxx.xxx.xxx.2:61616</connector>
            <connector name="master1">tcp://xxx.xxx.xxx.4:61616</connector>
        </connectors>

        <!-- Acceptors -->
        <acceptors>
            <!-- Acceptor for every supported protocol -->
            <acceptor name="artemis">tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>

            <!-- AMQP Acceptor.  Listens on default AMQP port for AMQP traffic.-->
            <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>

            <!-- STOMP Acceptor. -->
            <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true</acceptor>
        </acceptors>

        <cluster-connections>
            <cluster-connection name="master-master-cluster">
                <address></address>
                <connector-ref>master0</connector-ref>
                <use-duplicate-detection>true</use-duplicate-detection>
                <message-load-balancing>ON_DEMAND</message-load-balancing>
                <max-hops>1</max-hops>
                <static-connectors>
                    <connector-ref>master0</connector-ref>
                    <connector-ref>master1</connector-ref>
                </static-connectors>
            </cluster-connection>

        </cluster-connections>

        <ha-policy>
            <replication>
                <master>
                    <group-name>master0slave0discovery</group-name>
                    <!--we need this for auto failback-->
                    <check-for-live-server>true</check-for-live-server>
                </master>
            </replication>
        </ha-policy>

        <!-- Security config -->

        <security-settings>
            <security-setting match="#">
                <permission type="createNonDurableQueue" roles="amq,admin"/>
                <permission type="deleteNonDurableQueue" roles="amq,admin"/>
                <permission type="createDurableQueue" roles="amq,admin"/>
                <permission type="deleteDurableQueue" roles="amq,admin"/>
                <permission type="createAddress" roles="amq,admin"/>
                <permission type="deleteAddress" roles="amq,admin"/>
                <permission type="consume" roles="amq,admin"/>
                <permission type="browse" roles="amq,admin"/>
                <permission type="send" roles="amq,admin"/>
                <!-- we need this otherwise ./artemis data imp wouldn't work -->
                <permission type="manage" roles="amq,admin"/>
            </security-setting>
        </security-settings>

        <!-- Address config -->

        <addresses>
            <address name="exampleTopic">
                <multicast/>
            </address>
            <address name="exampleQueue">
                <anycast>
                    <queue name="jms.queue.exampleQueue"/>
                </anycast>
            </address>
        </addresses>

        <address-settings>
            <address-setting match="#">
                <dead-letter-address>DLQ</dead-letter-address>
                <expiry-address>ExpiryQueue</expiry-address>
                <redelivery-delay>0</redelivery-delay>

                <!-- Redistribution Delay is required  -->
                <redistribution-delay>1000</redistribution-delay>

                <!-- if max-size-bytes and max-size-messages were both enabled, the system will enter into paging
                                  based on the first attribute to hits the maximum value -->
                <!-- limit for the address in bytes, -1 means unlimited -->
                <max-size-bytes>-1</max-size-bytes>
                <!-- limit for the address in messages, -1 means unlimited -->
                <max-size-messages>-1</max-size-messages>
                <message-counter-history-day-limit>10</message-counter-history-day-limit>
                <address-full-policy>PAGE</address-full-policy>
                <auto-create-queues>true</auto-create-queues>
                <auto-create-addresses>true</auto-create-addresses>
                <auto-delete-queues>false</auto-delete-queues>
                <auto-delete-addresses>false</auto-delete-addresses>

                <!-- E-goi configurations -->
                <default-address-routing-type>ANYCAST</default-address-routing-type>
                <default-queue-routing-type>ANYCAST</default-queue-routing-type>
            </address-setting>
        </address-settings>

    </core>
</configuration>

The second master holds the following configuration:

<?xml version="1.0" encoding="UTF-8" standalone="no"?>

<configuration xmlns="urn:activemq"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:activemq /schema/artemis-configuration.xsd">
    <core xmlns="urn:activemq:core">

        <name>master1</name>
        <persistence-enabled>true</persistence-enabled>

        <bindings-directory>data/bindings</bindings-directory>

        <journal-directory>data/journal</journal-directory>
        <journal-datasync>true</journal-datasync>
        <journal-min-files>2</journal-min-files>
        <journal-pool-files>10</journal-pool-files>
        <journal-device-block-size>4096</journal-device-block-size>
        <journal-file-size>10M</journal-file-size>

        <large-messages-directory>data/largemessages</large-messages-directory>

        <paging-directory>data/paging</paging-directory>


        <!-- Connectors -->

        <connectors>
            <connector name="master0">tcp://xxx.xxx.xxx.2:61616</connector>
            <connector name="master1">tcp://xxx.xxx.xxx.4:61616</connector>
        </connectors>

        <!-- Acceptors -->
        <acceptors>
            <!-- Acceptor for every supported protocol -->
            <acceptor name="artemis">tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>

            <!-- AMQP Acceptor.  Listens on default AMQP port for AMQP traffic.-->
            <acceptor name="amqp">tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true</acceptor>

            <!-- STOMP Acceptor. -->
            <acceptor name="stomp">tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true</acceptor>
        </acceptors>

        <cluster-connections>
            <cluster-connection name="master-master-cluster">
                <address></address>
                <connector-ref>master1</connector-ref>
                <message-load-balancing>ON_DEMAND</message-load-balancing>
                <max-hops>1</max-hops>
                <static-connectors>
                    <connector-ref>master0</connector-ref>
                    <connector-ref>master1</connector-ref>
                </static-connectors>
            </cluster-connection>

        </cluster-connections>

        <ha-policy>
            <replication>
                <master>
                    <group-name>master1slave1discovery</group-name>
                    <!--we need this for auto failback-->
                    <check-for-live-server>true</check-for-live-server>
                </master>
            </replication>
        </ha-policy>

        <!-- Security config -->

        <security-settings>
            <security-setting match="#">
                <permission type="createNonDurableQueue" roles="amq,admin"/>
                <permission type="deleteNonDurableQueue" roles="amq,admin"/>
                <permission type="createDurableQueue" roles="amq,admin"/>
                <permission type="deleteDurableQueue" roles="amq,admin"/>
                <permission type="createAddress" roles="amq,admin"/>
                <permission type="deleteAddress" roles="amq,admin"/>
                <permission type="consume" roles="amq,admin"/>
                <permission type="browse" roles="amq,admin"/>
                <permission type="send" roles="amq,admin"/>
                <!-- we need this otherwise ./artemis data imp wouldn't work -->
                <permission type="manage" roles="amq,admin"/>
            </security-setting>
        </security-settings>

        <!-- Address config -->

        <addresses>
            <address name="exampleTopic">
                <multicast/>
            </address>
            <address name="exampleQueue">
                <anycast>
                    <queue name="jms.queue.exampleQueue"/>
                </anycast>
            </address>
        </addresses>

        <address-settings>
            <address-setting match="#">
                <dead-letter-address>DLQ</dead-letter-address>
                <expiry-address>ExpiryQueue</expiry-address>
                <redelivery-delay>0</redelivery-delay>

                <!-- Redistribution Delay is required  -->
                <redistribution-delay>1000</redistribution-delay>


                <!-- if max-size-bytes and max-size-messages were both enabled, the system will enter into paging
                                  based on the first attribute to hits the maximum value -->
                <!-- limit for the address in bytes, -1 means unlimited -->
                <max-size-bytes>-1</max-size-bytes>
                <!-- limit for the address in messages, -1 means unlimited -->
                <max-size-messages>-1</max-size-messages>
                <message-counter-history-day-limit>10</message-counter-history-day-limit>
                <address-full-policy>PAGE</address-full-policy>
                <auto-create-queues>true</auto-create-queues>
                <auto-create-addresses>true</auto-create-addresses>
                <auto-delete-queues>false</auto-delete-queues>
                <auto-delete-addresses>false</auto-delete-addresses>

                <!-- E-goi configurations -->
                <default-address-routing-type>ANYCAST</default-address-routing-type>
                <default-queue-routing-type>ANYCAST</default-queue-routing-type>
            </address-setting>
        </address-settings>

    </core>
</configuration>

Show

The current environment I'm working with is a Symmetric cluster of 2 master nodes, and I intend to add a slave node for each of the master. The first master has the following configuration: <?xml version= "1.0" encoding= "UTF-8" standalone= "no" ?> <configuration xmlns= "urn:activemq" xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation= "urn:activemq /schema/artemis-configuration.xsd" > <core xmlns= "urn:activemq:core" > <name> master0 </name> <persistence-enabled> true </persistence-enabled> <bindings-directory> data/bindings </bindings-directory> <journal-directory> data/journal </journal-directory> <journal-datasync> true </journal-datasync> <journal-min-files> 2 </journal-min-files> <journal-pool-files> 10 </journal-pool-files> <journal-device-block-size> 4096 </journal-device-block-size> <journal-file-size> 10M </journal-file-size> <large-messages-directory> data/largemessages </large-messages-directory> <paging-directory> data/paging </paging-directory>  <connectors> <connector name= "master0" > tcp://xxx.xxx.xxx.2:61616 </connector> <connector name= "master1" > tcp://xxx.xxx.xxx.4:61616 </connector> </connectors>  <acceptors>  <acceptor name= "artemis" > tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true </acceptor>  <acceptor name= "amqp" > tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true </acceptor>  <acceptor name= "stomp" > tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true </acceptor> </acceptors> <cluster-connections> <cluster-connection name= "master-master-cluster" > <address> </address> <connector-ref> master0 </connector-ref> <use-duplicate-detection> true </use-duplicate-detection> <message-load-balancing> ON_DEMAND </message-load-balancing> <max-hops> 1 </max-hops> <static-connectors> <connector-ref> master0 </connector-ref> <connector-ref> master1 </connector-ref> </static-connectors> </cluster-connection> </cluster-connections> <ha-policy> <replication> <master> <group-name> master0slave0discovery </group-name>  <check-for-live-server> true </check-for-live-server> </master> </replication> </ha-policy>  <security-settings> <security-setting match= "#" > <permission type= "createNonDurableQueue" roles= "amq,admin" /> <permission type= "deleteNonDurableQueue" roles= "amq,admin" /> <permission type= "createDurableQueue" roles= "amq,admin" /> <permission type= "deleteDurableQueue" roles= "amq,admin" /> <permission type= "createAddress" roles= "amq,admin" /> <permission type= "deleteAddress" roles= "amq,admin" /> <permission type= "consume" roles= "amq,admin" /> <permission type= "browse" roles= "amq,admin" /> <permission type= "send" roles= "amq,admin" />  <permission type= "manage" roles= "amq,admin" /> </security-setting> </security-settings>  <addresses> <address name= "exampleTopic" > <multicast/> </address> <address name= "exampleQueue" > <anycast> <queue name= "jms.queue.exampleQueue" /> </anycast> </address> </addresses> <address-settings> <address-setting match= "#" > <dead-letter-address> DLQ </dead-letter-address> <expiry-address> ExpiryQueue </expiry-address> <redelivery-delay> 0 </redelivery-delay>  <redistribution-delay> 1000 </redistribution-delay>   <max-size-bytes> -1 </max-size-bytes>  <max-size-messages> -1 </max-size-messages> <message-counter-history-day-limit> 10 </message-counter-history-day-limit> <address-full-policy> PAGE </address-full-policy> <auto-create-queues> true </auto-create-queues> <auto-create-addresses> true </auto-create-addresses> <auto-delete-queues> false </auto-delete-queues> <auto-delete-addresses> false </auto-delete-addresses>  <default-address-routing-type> ANYCAST </default-address-routing-type> <default-queue-routing-type> ANYCAST </default-queue-routing-type> </address-setting> </address-settings> </core> </configuration> The second master holds the following configuration: <?xml version= "1.0" encoding= "UTF-8" standalone= "no" ?> <configuration xmlns= "urn:activemq" xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation= "urn:activemq /schema/artemis-configuration.xsd" > <core xmlns= "urn:activemq:core" > <name> master1 </name> <persistence-enabled> true </persistence-enabled> <bindings-directory> data/bindings </bindings-directory> <journal-directory> data/journal </journal-directory> <journal-datasync> true </journal-datasync> <journal-min-files> 2 </journal-min-files> <journal-pool-files> 10 </journal-pool-files> <journal-device-block-size> 4096 </journal-device-block-size> <journal-file-size> 10M </journal-file-size> <large-messages-directory> data/largemessages </large-messages-directory> <paging-directory> data/paging </paging-directory>  <connectors> <connector name= "master0" > tcp://xxx.xxx.xxx.2:61616 </connector> <connector name= "master1" > tcp://xxx.xxx.xxx.4:61616 </connector> </connectors>  <acceptors>  <acceptor name= "artemis" > tcp://0.0.0.0:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true </acceptor>  <acceptor name= "amqp" > tcp://0.0.0.0:5672?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpLowCredits=300;amqpDuplicateDetection=true </acceptor>  <acceptor name= "stomp" > tcp://0.0.0.0:61613?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true </acceptor> </acceptors> <cluster-connections> <cluster-connection name= "master-master-cluster" > <address> </address> <connector-ref> master1 </connector-ref> <message-load-balancing> ON_DEMAND </message-load-balancing> <max-hops> 1 </max-hops> <static-connectors> <connector-ref> master0 </connector-ref> <connector-ref> master1 </connector-ref> </static-connectors> </cluster-connection> </cluster-connections> <ha-policy> <replication> <master> <group-name> master1slave1discovery </group-name>  <check-for-live-server> true </check-for-live-server> </master> </replication> </ha-policy>  <security-settings> <security-setting match= "#" > <permission type= "createNonDurableQueue" roles= "amq,admin" /> <permission type= "deleteNonDurableQueue" roles= "amq,admin" /> <permission type= "createDurableQueue" roles= "amq,admin" /> <permission type= "deleteDurableQueue" roles= "amq,admin" /> <permission type= "createAddress" roles= "amq,admin" /> <permission type= "deleteAddress" roles= "amq,admin" /> <permission type= "consume" roles= "amq,admin" /> <permission type= "browse" roles= "amq,admin" /> <permission type= "send" roles= "amq,admin" />  <permission type= "manage" roles= "amq,admin" /> </security-setting> </security-settings>  <addresses> <address name= "exampleTopic" > <multicast/> </address> <address name= "exampleQueue" > <anycast> <queue name= "jms.queue.exampleQueue" /> </anycast> </address> </addresses> <address-settings> <address-setting match= "#" > <dead-letter-address> DLQ </dead-letter-address> <expiry-address> ExpiryQueue </expiry-address> <redelivery-delay> 0 </redelivery-delay>  <redistribution-delay> 1000 </redistribution-delay>   <max-size-bytes> -1 </max-size-bytes>  <max-size-messages> -1 </max-size-messages> <message-counter-history-day-limit> 10 </message-counter-history-day-limit> <address-full-policy> PAGE </address-full-policy> <auto-create-queues> true </auto-create-queues> <auto-create-addresses> true </auto-create-addresses> <auto-delete-queues> false </auto-delete-queues> <auto-delete-addresses> false </auto-delete-addresses>  <default-address-routing-type> ANYCAST </default-address-routing-type> <default-queue-routing-type> ANYCAST </default-queue-routing-type> </address-setting> </address-settings> </core> </configuration>

Description

Before ~~ARTEMIS-3918~~, redistribution of FQQN ANYCAST messages was not working as stated in the issue itself. The problem was solved, however, in my use case, the redistribution is being made into different queues of the same address.

I'm using addresses to group queues from different applications, so the address name is the name of the application and all the application queues are inside it. I understand this is not the original concept of addresses yet it helps in organizing everything.

I was waiting for ~~ARTEMIS-3918~~ since redistribution in FQQN ANYCAST queues was not working before it. I've updated the cluster to 2.25.0 and redistribution is working, however I was faced with the problem that redistributed messages were often redistributed to another queue in the address (i.e. a message placed in the "test:test1" FQQN was placed into "test::test2" FQQN) which caused some errors in the application.

I've discussed with jbertram in the ARTEMIS-3918 PR and it seems the behavior should be to redistribute the message into the same exact same FQQN queue and so I'm reporting this behavior. From what I've seen from the code, the test case created seems to only test an address with a single queue, maybe adding one more queue might improve the test's effectiveness.

How To Replicate

The behavior was fairly easy to replicate using the artemis command line utility, here's how to replicate it:

Create a symmetric cluster of 2 master nodes

On 1 of the nodes, setup 2 consumers, one for each queue in the same address:

artemis consumer --destination queue://test::test1 --verbose
artemis consumer --destination queue://test::test2 --verbose

On the other node, produce some messages into one of the queues:

artemis producer --message-count 20 --destination queue://test::test2 --verbose

You should see messages being consumed by both consumers instead of only the consumer for "queue://test::test2"

My Test Results:

Note: It is best to first setup the consumers and only then the producer.

Node 1 - Producer:

[root@node1 ~]# /usr/lib64/artemis/bin/artemis producer --message-count 200 --destination queue://test::test2 --verbose
Executing org.apache.activemq.artemis.cli.commands.messages.Producer producer --message-count 200 --destination queue://test::test2 --verbose 
Home::/usr/lib64/artemis, Instance::null
Connection brokerURL = tcp://localhost:61616
Connection failed::AMQ229031: Unable to validate user from /127.0.0.1:33148. Username: null; SSL certificate subject DN: unavailable

--user:
Type the username for a retry
xxxxx

--password: is mandatory with this configuration:
Type the password for a retry

Producer ActiveMQQueue[test::test2], thread=0 Started to calculate elapsed time ...

Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 0
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 1
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 2
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 3
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 4
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 5
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 6
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 7
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 8
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 9
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 10
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 11
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 12
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 13
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 14
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 15
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 16
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 17
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 18
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 19
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 20
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 21
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 22
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 23
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 24
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 25
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 26
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 27
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 28
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 29
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 30
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 31
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 32
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 33
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 34
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 35
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 36
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 37
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 38
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 39
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 40
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 41
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 42
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 43
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 44
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 45
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 46
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 47
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 48
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 49
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 50
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 51
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 52
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 53
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 54
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 55
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 56
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 57
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 58
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 59
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 60
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 61
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 62
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 63
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 64
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 65
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 66
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 67
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 68
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 69
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 70
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 71
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 72
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 73
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 74
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 75
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 76
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 77
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 78
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 79
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 80
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 81
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 82
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 83
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 84
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 85
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 86
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 87
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 88
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 89
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 90
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 91
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 92
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 93
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 94
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 95
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 96
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 97
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 98
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 99
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 100
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 101
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 102
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 103
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 104
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 105
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 106
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 107
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 108
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 109
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 110
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 111
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 112
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 113
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 114
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 115
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 116
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 117
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 118
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 119
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 120
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 121
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 122
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 123
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 124
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 125
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 126
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 127
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 128
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 129
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 130
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 131
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 132
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 133
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 134
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 135
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 136
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 137
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 138
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 139
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 140
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 141
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 142
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 143
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 144
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 145
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 146
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 147
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 148
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 149
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 150
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 151
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 152
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 153
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 154
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 155
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 156
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 157
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 158
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 159
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 160
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 161
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 162
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 163
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 164
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 165
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 166
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 167
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 168
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 169
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 170
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 171
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 172
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 173
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 174
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 175
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 176
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 177
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 178
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 179
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 180
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 181
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 182
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 183
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 184
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 185
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 186
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 187
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 188
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 189
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 190
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 191
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 192
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 193
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 194
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 195
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 196
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 197
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 198
Producer ActiveMQQueue[test::test2], thread=0 Sent: test message: 199
Producer ActiveMQQueue[test::test2], thread=0 Produced: 200 messages
Producer ActiveMQQueue[test::test2], thread=0 Elapsed time in second : 1 s
Producer ActiveMQQueue[test::test2], thread=0 Elapsed time in milli second : 1157 milli seconds

Node 2 - Consumer "test::test1":

[root@node2 ~]# /usr/lib64/artemis/bin/artemis consumer --destination queue://test::test1 --verbose
Executing org.apache.activemq.artemis.cli.commands.messages.Consumer consumer --destination queue://test::test1 --verbose 
Home::/usr/lib64/artemis, Instance::null
Connection brokerURL = tcp://localhost:61616
Consumer:: filter = null
Connection failed::AMQ229031: Unable to validate user from /127.0.0.1:53768. Username: null; SSL certificate subject DN: unavailable

--user:
Type the username for a retry
xxxx

--password: is mandatory with this configuration:
Type the password for a retry

Consumer ActiveMQQueue[test::test1], thread=0 wait until 1000 messages are consumed
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 1
JMS Message ID:ID:92e0c4fd-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 3
JMS Message ID:ID:92e2248f-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 5
JMS Message ID:ID:92e38421-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 7
JMS Message ID:ID:92e5ce13-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 9
JMS Message ID:ID:92eab015-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 11
JMS Message ID:ID:92ed2117-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 13
JMS Message ID:ID:92eef5d9-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 15
JMS Message ID:ID:92f0a38b-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 17
JMS Message ID:ID:92f2031d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 19
JMS Message ID:ID:92f3b0cf-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 21
JMS Message ID:ID:92f4e951-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 23
JMS Message ID:ID:92f648e3-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 25
JMS Message ID:ID:92f86bc5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 27
JMS Message ID:ID:92fab5b7-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 29
JMS Message ID:ID:92fcb189-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 31
JMS Message ID:ID:92ffbecb-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 33
JMS Message ID:ID:93011e5d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 35
JMS Message ID:ID:9303413f-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 37
JMS Message ID:ID:9305b241-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 39
JMS Message ID:ID:9307ae13-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 41
JMS Message ID:ID:930934b5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 43
JMS Message ID:ID:930b3087-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 45
JMS Message ID:ID:930c9019-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 47
JMS Message ID:ID:930e8beb-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 49
JMS Message ID:ID:931123fd-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 51
JMS Message ID:ID:9312838f-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 53
JMS Message ID:ID:93140a31-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 55
JMS Message ID:ID:931569c3-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 57
JMS Message ID:ID:93171775-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 59
JMS Message ID:ID:93189e17-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 61
JMS Message ID:ID:931a72d9-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 63
JMS Message ID:ID:931c208b-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 65
JMS Message ID:ID:931d590d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 67
JMS Message ID:ID:931f06bf-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 69
JMS Message ID:ID:93206651-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 71
JMS Message ID:ID:93223b13-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 73
JMS Message ID:ID:9323c1b5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 75
JMS Message ID:ID:93254857-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 77
JMS Message ID:ID:9326cef9-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 79
JMS Message ID:ID:93282e8b-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 81
JMS Message ID:ID:9329b52d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 83
JMS Message ID:ID:932b62df-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 85
JMS Message ID:ID:932cc271-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 87
JMS Message ID:ID:932e4913-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 89
JMS Message ID:ID:932fcfb5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 91
JMS Message ID:ID:93312f47-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 93
JMS Message ID:ID:93328ed9-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 95
JMS Message ID:ID:9333ee6b-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 97
JMS Message ID:ID:9335750d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 99
JMS Message ID:ID:9336d49f-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 101
JMS Message ID:ID:93383331-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 103
JMS Message ID:ID:933992c3-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 105
JMS Message ID:ID:933af255-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 107
JMS Message ID:ID:933c78f7-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 109
JMS Message ID:ID:933e26a9-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 111
JMS Message ID:ID:933fd45b-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 113
JMS Message ID:ID:934133ed-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 115
JMS Message ID:ID:934356cf-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 117
JMS Message ID:ID:93463d01-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 119
JMS Message ID:ID:934886f3-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 121
JMS Message ID:ID:934a34a5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 123
JMS Message ID:ID:934c0967-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 125
JMS Message ID:ID:934db719-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 127
JMS Message ID:ID:934f8bdb-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 129
JMS Message ID:ID:9351398d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 131
JMS Message ID:ID:9352c02f-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 133
JMS Message ID:ID:9354e311-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 135
JMS Message ID:ID:935642a3-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 137
JMS Message ID:ID:9357c945-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 139
JMS Message ID:ID:935901c7-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 141
JMS Message ID:ID:935aaf79-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 143
JMS Message ID:ID:935be7fb-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 145
JMS Message ID:ID:935d95ad-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 147
JMS Message ID:ID:935fdf9f-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 149
JMS Message ID:ID:93616641-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 151
JMS Message ID:ID:93638923-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 153
JMS Message ID:ID:93655de5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 155
JMS Message ID:ID:93670b97-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 157
JMS Message ID:ID:9368b949-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 159
JMS Message ID:ID:936a18db-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 161
JMS Message ID:ID:936b786d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 163
JMS Message ID:ID:936cff0f-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 165
JMS Message ID:ID:936e5ea1-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 167
JMS Message ID:ID:936f9723-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 169
JMS Message ID:ID:9370f6b5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 171
JMS Message ID:ID:9372a467-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 173
JMS Message ID:ID:937403f9-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 175
JMS Message ID:ID:9375638b-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 177
JMS Message ID:ID:9376c31d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 179
JMS Message ID:ID:937897df-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 181
JMS Message ID:ID:937a1e81-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 183
JMS Message ID:ID:937b7e13-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 185
JMS Message ID:ID:937d04b5-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 187
JMS Message ID:ID:937e8b57-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 189
JMS Message ID:ID:938011f9-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 191
JMS Message ID:ID:9381718b-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 193
JMS Message ID:ID:93831f3d-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 195
JMS Message ID:ID:9384a5df-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 197
JMS Message ID:ID:9386a1b1-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test1], thread=0 Received test message: 199
JMS Message ID:ID:9387da33-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17

Node 2 - Consumer "test::test2":

[root@node2 ~]# /usr/lib64/artemis/bin/artemis consumer --destination queue://test::test2 --verbose
Executing org.apache.activemq.artemis.cli.commands.messages.Consumer consumer --destination queue://test::test2 --verbose 
Home::/usr/lib64/artemis, Instance::null
Connection brokerURL = tcp://localhost:61616
Consumer:: filter = null
Connection failed::AMQ229031: Unable to validate user from /127.0.0.1:53718. Username: null; SSL certificate subject DN: unavailable

--user:
Type the username for a retry
xxxxx

--password: is mandatory with this configuration:
Type the password for a retry

Consumer ActiveMQQueue[test::test2], thread=0 wait until 1000 messages are consumed
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 0
JMS Message ID:ID:92dbe2fc-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 2
JMS Message ID:ID:92e1884e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 4
JMS Message ID:ID:92e2c0d0-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 6
JMS Message ID:ID:92e46e82-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 8
JMS Message ID:ID:92e754b4-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 15
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 10
JMS Message ID:ID:92ec36b6-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 12
JMS Message ID:ID:92ee0b78-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 14
JMS Message ID:ID:92efb92a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 16
JMS Message ID:ID:92f13fcc-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 18
JMS Message ID:ID:92f29f5e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 20
JMS Message ID:ID:92f42600-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 22
JMS Message ID:ID:92f5d3b2-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 24
JMS Message ID:ID:92f70c34-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 26
JMS Message ID:ID:92f97d36-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 28
JMS Message ID:ID:92fb7908-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 30
JMS Message ID:ID:92fdea0a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 32
JMS Message ID:ID:93005b0c-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 34
JMS Message ID:ID:9301e1ae-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 36
JMS Message ID:ID:930479c0-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 38
JMS Message ID:ID:9306eac2-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 40
JMS Message ID:ID:93087164-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 42
JMS Message ID:ID:930a6d36-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 44
JMS Message ID:ID:930bf3d8-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 46
JMS Message ID:ID:930d536a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 48
JMS Message ID:ID:930fc46c-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 50
JMS Message ID:ID:9311e74e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 52
JMS Message ID:ID:931346e0-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 54
JMS Message ID:ID:9314cd82-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 56
JMS Message ID:ID:93162d14-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 58
JMS Message ID:ID:9317dac6-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 60
JMS Message ID:ID:93193a58-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 62
JMS Message ID:ID:931b5d3a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 64
JMS Message ID:ID:931c95bc-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 66
JMS Message ID:ID:931e1c5e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 68
JMS Message ID:ID:931fa300-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 70
JMS Message ID:ID:932129a2-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 72
JMS Message ID:ID:9322fe64-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 74
JMS Message ID:ID:93248506-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 76
JMS Message ID:ID:9325e498-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 78
JMS Message ID:ID:93276b3a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 80
JMS Message ID:ID:9328f1dc-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 82
JMS Message ID:ID:932a9f8e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 84
JMS Message ID:ID:932bff20-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 86
JMS Message ID:ID:932d85c2-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 88
JMS Message ID:ID:932f0c64-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 90
JMS Message ID:ID:93309306-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 92
JMS Message ID:ID:9331cb88-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 94
JMS Message ID:ID:9333522a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 96
JMS Message ID:ID:9334b1bc-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 98
JMS Message ID:ID:9336114e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 16
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 100
JMS Message ID:ID:933796f0-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 102
JMS Message ID:ID:9338cf72-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 104
JMS Message ID:ID:933a5614-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 106
JMS Message ID:ID:933bb5a6-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 108
JMS Message ID:ID:933d6358-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 110
JMS Message ID:ID:933ee9fa-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 112
JMS Message ID:ID:9340709c-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 114
JMS Message ID:ID:9341f73e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 116
JMS Message ID:ID:93450480-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 118
JMS Message ID:ID:93477582-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 120
JMS Message ID:ID:9348fc24-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 122
JMS Message ID:ID:934b1f06-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 124
JMS Message ID:ID:934cccb8-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 126
JMS Message ID:ID:934ea17a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 128
JMS Message ID:ID:93504f2c-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 130
JMS Message ID:ID:9351fcde-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 132
JMS Message ID:ID:9353d1a0-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 134
JMS Message ID:ID:93557f52-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 136
JMS Message ID:ID:935705f4-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 138
JMS Message ID:ID:93586586-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 140
JMS Message ID:ID:9359ec28-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 142
JMS Message ID:ID:935b4bba-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 144
JMS Message ID:ID:935cab4c-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 146
JMS Message ID:ID:935ea71e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 148
JMS Message ID:ID:93607be0-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 150
JMS Message ID:ID:93622992-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 152
JMS Message ID:ID:93647384-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 154
JMS Message ID:ID:93662136-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 156
JMS Message ID:ID:9367f5f8-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 158
JMS Message ID:ID:93697c9a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 160
JMS Message ID:ID:936adc2c-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 162
JMS Message ID:ID:936c3bbe-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 164
JMS Message ID:ID:936d9b50-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 166
JMS Message ID:ID:936ed3d2-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 168
JMS Message ID:ID:93703364-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 170
JMS Message ID:ID:9371e116-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 172
JMS Message ID:ID:937367b8-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 174
JMS Message ID:ID:9374ee5a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 176
JMS Message ID:ID:937626dc-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 178
JMS Message ID:ID:93775f5e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 180
JMS Message ID:ID:93798240-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 182
JMS Message ID:ID:937ae1d2-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 184
JMS Message ID:ID:937c4164-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 186
JMS Message ID:ID:937dc806-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 188
JMS Message ID:ID:937f4ea8-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 190
JMS Message ID:ID:9380ae3a-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 192
JMS Message ID:ID:938282fc-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 194
JMS Message ID:ID:9383e28e-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 196
JMS Message ID:ID:93854220-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17
Consumer ActiveMQQueue[test::test2], thread=0 Received test message: 198
JMS Message ID:ID:938716e2-3dcc-11ed-a98b-0ed9fe01ac83
Received text sized at 17

Attachments

Activity

People

Assignee:: Unassigned

Reporter:: João Santos

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 26/Sep/22 19:02

Updated:: 22/Aug/23 17:42