[
https://issues.apache.org/jira/browse/ARTEMIS-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17757589#comment-17757589
]
João Santos commented on ARTEMIS-4017:
--------------------------------------
[~clebertsuconic] and [~jbertram] I've just tested this again with 2.30.0 and
it still occurs, I'll keep the issue open for the time being as this is
preventing me from creating a synchronous cluster with message redistribution.
> FQQN Anycast Redistribution on a symmetric cluster is redistributing to
> different FQQN in the same address
> ----------------------------------------------------------------------------------------------------------
>
> Key: ARTEMIS-4017
> URL: https://issues.apache.org/jira/browse/ARTEMIS-4017
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: Broker
> Affects Versions: 2.25.0
> Environment: 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:
> {code:xml}
> <?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>
> {code}
> The second master holds the following configuration:
> {code:xml}
> <?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>
> {code}
> Reporter: João Santos
> Priority: Critical
>
> 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|https://github.com/apache/activemq-artemis/pull/4167#issuecomment-1258324426]
> 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:
> {code:bash}
> artemis consumer --destination queue://test::test1 --verbose
> artemis consumer --destination queue://test::test2 --verbose
> {code}
> # On the other node, produce some messages into one of the queues:
> {code:bash}
> artemis producer --message-count 20 --destination queue://test::test2
> --verbose
> {code}
> # 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:*
> {code:none}
> [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
> {code}
> *Node 2 - Consumer "test::test1":*
> {code:none}
> [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
> {code}
> *Node 2 - Consumer "test::test2":*
> {code:none}
> [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
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
