You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "João Santos (Jira)" <ji...@apache.org> on 2022/12/05 21:44:00 UTC
[jira] [Commented] (ARTEMIS-4017) FQQN Anycast Redistribution on a symmetric cluster is redistributing to different FQQN in the same address
[ https://issues.apache.org/jira/browse/ARTEMIS-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643562#comment-17643562 ]
João Santos commented on ARTEMIS-4017:
--------------------------------------
Hey [~jbertram], when would you be able to re-evaluate this problem? Is there something else we can provide in order to help this issue's analysis?
> 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)