You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "StanislavKo (JIRA)" <ji...@apache.org> on 2017/12/17 21:07:00 UTC
[jira] [Commented] (ARTEMIS-1501) External ArtemisMQ 2.3 cluster
doesn't work
[ https://issues.apache.org/jira/browse/ARTEMIS-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16294334#comment-16294334 ]
StanislavKo commented on ARTEMIS-1501:
--------------------------------------
Cluster doesn't work.
Artemis ver.2.4.0.
I ran {{clustered-queue}}, for instance. 2 nodes. web console shows {{my-cluster}} with 2 nodes (1 external node in "Nodes" property).
I sent 4 messages to the first node. Consumer received 2 messages only.
The 1st node web console shows queue attribute "Messages added" = 2. The 2st node web console shows queue attribute "Messages added" = 0.
2 messages are understandable: STRICT policy requires half messages go to the 2nd node. But "Messages added" = 0 says that 2nd node didn't receive them.
> External ArtemisMQ 2.3 cluster doesn't work
> --------------------------------------------
>
> Key: ARTEMIS-1501
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1501
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Affects Versions: 2.3.0
> Environment: Ubuntu 15 Desktop, java 8
> Reporter: StanislavKo
>
> External ArtemisMQ 1.5.4 cluster works except redistribution functionality (redistribution-delay 0)
> External ArtemisMQ 2.3 cluster doesn't work. It sends messages to another nodes but another node denies to accept them (stack trace below).
> 14:36:53,595 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl] Couldn't find any bindings for address=jms.queue.NewItem on message=CoreMessage[messageID=491,durable=true,userID=f75cff43-c292-11e7-bfb0-ef1bf8dd85f9,priority=4, timestamp=Mon Nov 04 14:36:52 MSK 2017,expiration=0, durable=true, address=jms.queue.NewItem,properties=TypedProperties[__AMQ_CID=f6d4955f-c292-11e7-bfb0-ef1bf8dd85f9,type=IMAGE,counter=1,_AMQ_ROUTE_TO=[0000 0000 0000 000C),bytesAsLongs(12],url=http://icons.iconarchive.com/icons/seanau/email/256/Clear-icon.png]]@247622711
> 14:36:53,595 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl] Message CoreMessage[messageID=491,durable=true,userID=f75cff43-c292-11e7-bfb0-ef1bf8dd85f9,priority=4, timestamp=Mon Nov 04 14:36:52 MSK 2017,expiration=0, durable=true,
> address=jms.queue.NewItem,properties=TypedProperties[__AMQ_CID=f6d4955f-c292-11e7-bfb0-ef1bf8dd85f9,type=IMAGE,counter=1,_AMQ_ROUTE_TO=[0000 0000 0000 000C),bytesAsLongs(12],url=http://icons.iconarchive.com/icons/seanau/email/256/Clear-icon.png]]@247622711 is not going anywhere as it didn't have a binding on address:jms.queue.NewItem
> broker.xml for ver.2.3:
> {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" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="urn:activemq:core ">
> <name>192.168.0.85</name>
> <persistence-enabled>true</persistence-enabled>
> <journal-type>NIO</journal-type>
> <paging-directory>./data/paging</paging-directory>
> <bindings-directory>./data/bindings</bindings-directory>
> <journal-directory>./data/journal</journal-directory>
> <large-messages-directory>./data/large-messages</large-messages-directory>
> <journal-datasync>true</journal-datasync>
> <journal-min-files>2</journal-min-files>
> <journal-pool-files>-1</journal-pool-files>
> <journal-buffer-timeout>5896000</journal-buffer-timeout>
> <!-- how often we are looking for how many bytes are being used on the disk in ms -->
> <disk-scan-period>5000</disk-scan-period>
> <!-- once the disk hits this limit the system will block, or close the connection in certain protocols
> that won't support flow control. -->
> <max-disk-usage>90</max-disk-usage>
> <!-- should the broker detect dead locks and other issues -->
> <critical-analyzer>true</critical-analyzer>
> <critical-analyzer-timeout>120000</critical-analyzer-timeout>
> <critical-analyzer-check-period>60000</critical-analyzer-check-period>
> <critical-analyzer-policy>HALT</critical-analyzer-policy>
> <!-- Connectors -->
> <connectors>
> <connector name="netty-connector">tcp://192.168.0.85:61616</connector>
> <!-- connector to the server86 -->
> <!-- <connector name="server86-connector">tcp://192.168.0.86:61616</connector> -->
> </connectors>
> <!-- Acceptors -->
> <acceptors>
> <acceptor name="netty-acceptor">tcp://192.168.0.85:61616</acceptor>
> </acceptors>
> <!-- Clustering configuration -->
> <broadcast-groups>
> <broadcast-group name="my-broadcast-group">
> <group-address>${udp-address:231.7.7.7}</group-address>
> <group-port>9876</group-port>
> <broadcast-period>100</broadcast-period>
> <connector-ref>netty-connector</connector-ref>
> </broadcast-group>
> </broadcast-groups>
> <discovery-groups>
> <discovery-group name="my-discovery-group">
> <group-address>${udp-address:231.7.7.7}</group-address>
> <group-port>9876</group-port>
> <refresh-timeout>10000</refresh-timeout>
> </discovery-group>
> </discovery-groups>
> <!-- Clustering configuration -->
> <cluster-connections>
> <cluster-connection name="my-cluster">
> <connector-ref>netty-connector</connector-ref>
> <retry-interval>500</retry-interval>
> <use-duplicate-detection>true</use-duplicate-detection>
> <!-- ON_DEMAND STRICT -->
> <message-load-balancing>STRICT</message-load-balancing>
> <max-hops>1</max-hops>
> <discovery-group-ref discovery-group-name="my-discovery-group"/>
> <!-- <static-connectors>
> <connector-ref>server86-connector</connector-ref>
> </static-connectors> -->
> </cluster-connection>
> </cluster-connections>
> <!-- Other config -->
> <security-settings>
> <security-setting match="#">
> <permission roles="amq" type="createDurableQueue"/>
> <permission roles="amq" type="deleteDurableQueue"/>
> <permission roles="amq" type="createNonDurableQueue"/>
> <permission roles="amq" type="deleteNonDurableQueue"/>
> <permission roles="amq" type="consume"/>
> <permission roles="amq" type="send"/>
> <permission type="browse" roles="amq"/>
> <permission type="manage" roles="amq"/>
> </security-setting>
> </security-settings>
> <address-settings>
> <!-- if you define auto-create on certain queues, management has to be auto-create -->
> <address-setting match="activemq.management#">
> <dead-letter-address>DLQ</dead-letter-address>
> <expiry-address>ExpiryQueue</expiry-address>
> <redelivery-delay>0</redelivery-delay>
> <!-- with -1 only the global-max-size is in use for limiting -->
> <max-size-bytes>-1</max-size-bytes>
> <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-create-jms-queues>true</auto-create-jms-queues>
> <auto-create-jms-topics>true</auto-create-jms-topics>
> </address-setting>
> <!--default for catch all-->
> <address-setting match="#">
> <dead-letter-address>DLQ</dead-letter-address>
> <expiry-address>ExpiryQueue</expiry-address>
> <redelivery-delay>0</redelivery-delay>
> <!-- with -1 only the global-max-size is in use for limiting -->
> <max-size-bytes>-1</max-size-bytes>
> <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-create-jms-queues>true</auto-create-jms-queues>
> <auto-create-jms-topics>true</auto-create-jms-topics>
> <redistribution-delay>0</redistribution-delay>
> </address-setting>
> </address-settings>
> <addresses>
> <address name="DLQ">
> <anycast>
> <queue name="DLQ" />
> </anycast>
> </address>
> <address name="ExpiryQueue">
> <anycast>
> <queue name="ExpiryQueue" />
> </anycast>
> </address>
> <address name="NewItem">
> <anycast>
> <queue name="NewItem"/>
> </anycast>
> </address>
> <address name="DeleteItem">
> <anycast>
> <queue name="DeleteItem"/>
> </anycast>
> </address>
> <address name="InaccessibleItem">
> <anycast>
> <queue name="InaccessibleItem"/>
> </anycast>
> </address>
> <!-- <address name="jms.queue.NewItem">
> <anycast>
> <queue name="NewItem"/>
> </anycast>
> </address>
> <address name="jms.queue.DeleteItem">
> <anycast>
> <queue name="DeleteItem"/>
> </anycast>
> </address>
> <address name="jms.queue.InaccessibleItem">
> <anycast>
> <queue name="InaccessibleItem"/>
> </anycast>
> </address> -->
> </addresses>
> </core>
> </configuration>
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)