activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "StanislavKo (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (ARTEMIS-1501) External ArtemisMQ 2.3 cluster doesn't work
Date Mon, 06 Nov 2017 07:39:00 GMT

    [ https://issues.apache.org/jira/browse/ARTEMIS-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16240001#comment-16240001
] 

StanislavKo edited comment on ARTEMIS-1501 at 11/6/17 7:38 AM:
---------------------------------------------------------------

No. 2 nodes with 1.5.4 work almost fine. 2 nodes with 2.3.0 don't work to me.


was (Author: stanislavko):
No. 2 nodes with 1.5.4 works almost fine. 2 nodes with 2.3.0 don't work to me.

> 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 for example topic-->
>          <security-setting match="exampleTopic">
>             <permission roles="amq" type="createDurableQueue"/>
>             <permission roles="amq" type="deleteDurableQueue"/>
>             <permission roles="amq" type="createAddress"/>
>             <permission roles="amq" type="deleteAddress"/>
>             <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-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)

Mime
View raw message