From dev-return-70626-archive-asf-public=cust-asf.ponee.io@activemq.apache.org  Mon May 27 23:44:21 2019
Return-Path: <dev-return-70626-archive-asf-public=cust-asf.ponee.io@activemq.apache.org>
X-Original-To: archive-asf-public@cust-asf.ponee.io
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [207.244.88.153])
	by mx-eu-01.ponee.io (Postfix) with SMTP id AF133180638
	for <archive-asf-public@cust-asf.ponee.io>; Tue, 28 May 2019 01:44:20 +0200 (CEST)
Received: (qmail 40977 invoked by uid 500); 27 May 2019 23:44:19 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Delivered-To: moderator for dev@activemq.apache.org
Received: (qmail 35539 invoked by uid 99); 27 May 2019 20:18:48 -0000
X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 2.234
X-Spam-Level: **
X-Spam-Status: No, score=2.234 tagged_above=-999 required=6.31
	tests=[KAM_SHORT=0.001, RCVD_IN_DNSWL_NONE=-0.0001, SPF_FAIL=0.919,
	SPF_HELO_PASS=-0.001, URIBL_BLOCKED=0.001, URI_HEX=1.313,
	URI_TRY_3LD=0.001] autolearn=disabled
Date: Mon, 27 May 2019 15:11:24 -0500 (CDT)
From: adyr <adrian.rafaila@sphs.ro>
To: dev@activemq.apache.org
Message-ID: <1558987884264-0.post@n4.nabble.com>
Subject: Artemis 2.8 master-slave cluster with shared-store, no messages
 after failover
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hello,

I configured a master-slave cluster using a NFS shared storage.
The failback works, when masters goes down, the slaves comes up and take the
queues.
Unfortunately, after the slave comes up, there are no messages in any queue.
(as well when the master comes back live).

Master config:
<?xml version="1.0"?>

<configuration xmlns="urn:activemq"
               xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
               xmlns:xi="http://www.w3.org/2001/XInclude"
               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 ">

       
<bindings-directory>/shared_storage/apache-artemis/data/bindings</bindings-directory>
        <journal-type>ASYNCIO</journal-type>
       
<journal-directory>/shared_storage/apache-artemis/data/journal</journal-directory>
       
<large-messages-directory>/shared_storage/apache-artemis/data/largemessages</large-messages-directory>
       
<paging-directory>/shared_storage/apache-artemis/data/paging</paging-directory>
        <journal-pool-files>100000</journal-pool-files>
        <max-disk-usage>-1</max-disk-usage>
        <persistance-enabled>true</persistance-enabled>

        <cluster-user>user</cluster-user>
        <cluster-password>pass</cluster-password>

        <ha-policy>
                <shared-store>
                        <master>
                               
<failover-on-shutdown>true</failover-on-shutdown>
                        </master>
                </shared-store>
        </ha-policy>

        <cluster-connections>
                <cluster-connection name="il-prod-cluster">
                        <connector-ref>master-connector</connector-ref>
                       
<message-load-balancing>ON_DEMAND</message-load-balancing>
                        <static-connectors>
                               
<connector-ref>slave-connector</connector-ref>
                        </static-connectors>
                </cluster-connection>
        </cluster-connections>

        <connectors>
            <connector
name="master-connector">tcp://master_ip:61616</connector>
            <connector
name="slave-connector">tcp://slave_ip:61616</connector>
        </connectors>

        <acceptors>
                <acceptor
name="netty-acceptor">tcp://0.0.0.0:61616</acceptor>
        </acceptors>

        <security-settings>
         <security-setting match="#">
            <permission type="createNonDurableQueue" roles="amq"/>
            <permission type="deleteNonDurableQueue" roles="amq"/>
            <permission type="createDurableQueue" roles="amq"/>
            <permission type="deleteDurableQueue" roles="amq"/>
            <permission type="createAddress" roles="amq"/>
            <permission type="deleteAddress" roles="amq"/>
            <permission type="consume" roles="amq"/>
            <permission type="browse" roles="amq"/>
            <permission type="send" roles="amq"/>
            <permission type="manage" roles="amq"/>
         </security-setting>
      </security-settings>
        <address-settings>
         <address-setting match="#">
            <dead-letter-address>DLQ</dead-letter-address>
            <expiry-address>ExpiryQueue</expiry-address>
            <redelivery-delay>0</redelivery-delay>
            <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>
        </address-settings>

      <addresses>
         <address name="DLQ">
            <anycast>
               <queue name="DLQ" />
            </anycast>
         </address>
         <address name="ExpiryQueue">
            <anycast>
               <queue name="ExpiryQueue" />
            </anycast>
         </address>

      </addresses>

   </core>
</configuration>


slave config:
<?xml version="1.0"?>

<configuration xmlns="urn:activemq"
               xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
               xmlns:xi="http://www.w3.org/2001/XInclude"
               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 ">

       
<bindings-directory>/shared_storage/apache-artemis/data/bindings</bindings-directory>
        <journal-type>ASYNCIO</journal-type>
       
<journal-directory>/shared_storage/apache-artemis/data/journal</journal-directory>
       
<large-messages-directory>/shared_storage/apache-artemis/data/largemessages</large-messages-directory>
       
<paging-directory>/shared_storage/apache-artemis/data/paging</paging-directory>
        <journal-pool-files>100000</journal-pool-files>
        <max-disk-usage>-1</max-disk-usage>
        <persistence-enabled>true</persistence-enabled>

        <cluster-user>user</cluster-user>
        <cluster-password>pass</cluster-password>

        <ha-policy>
                <shared-store>
                        <slave>
                                <failback-delay>3000</failback-delay>
                                <allow-failback>true</allow-failback>
                        </slave>
                </shared-store>
        </ha-policy>

        <cluster-connections>
                <cluster-connection name="il-prod-cluster">
                        <connector-ref>slave-connector</connector-ref>
                       
<message-load-balancing>ON_DEMAND</message-load-balancing>
                        <static-connectors>
                               
<connector-ref>master-connector</connector-ref>
                        </static-connectors>
                </cluster-connection>
        </cluster-connections>

        <connectors>
            <connector
name="master-connector">tcp://master_ip:61616</connector>
            <connector
name="slave-connector">tcp://slave_ip:61616</connector>
        </connectors>

        <acceptors>
                <acceptor
name="netty-acceptor">tcp://0.0.0.0:61616</acceptor>
        </acceptors>

        <security-settings>
         <security-setting match="#">
            <permission type="createNonDurableQueue" roles="amq"/>
            <permission type="deleteNonDurableQueue" roles="amq"/>
            <permission type="createDurableQueue" roles="amq"/>
            <permission type="deleteDurableQueue" roles="amq"/>
            <permission type="createAddress" roles="amq"/>
            <permission type="deleteAddress" roles="amq"/>
            <permission type="consume" roles="amq"/>
            <permission type="browse" roles="amq"/>
            <permission type="send" roles="amq"/>
            <permission type="manage" roles="amq"/>
         </security-setting>
      </security-settings>

        <address-settings>
         <address-setting match="#">
            <dead-letter-address>DLQ</dead-letter-address>
            <expiry-address>ExpiryQueue</expiry-address>
            <redelivery-delay>0</redelivery-delay>
            <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>
        </address-settings>

      <addresses>
         <address name="DLQ">
            <anycast>
               <queue name="DLQ" />
            </anycast>
         </address>
         <address name="ExpiryQueue">
            <anycast>
               <queue name="ExpiryQueue" />
            </anycast>
         </address>

      </addresses>

   </core>
</configuration>



What I'm doing wrong or what am I missing?





--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-Dev-f2368404.html