You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "clebert suconic (JIRA)" <ji...@apache.org> on 2017/05/12 19:34:04 UTC
[jira] [Closed] (ARTEMIS-1161) HA Replication Failback Failure
[ https://issues.apache.org/jira/browse/ARTEMIS-1161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
clebert suconic closed ARTEMIS-1161.
------------------------------------
Resolution: Duplicate
this is fixed on 2.1.0
> HA Replication Failback Failure
> -------------------------------
>
> Key: ARTEMIS-1161
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1161
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: Broker
> Affects Versions: 2.0.0
> Reporter: Andrei Bercu
>
> We are running Artemis 2.0.0 in a master/slave setup (1 master, 1 slave) using replication.
> We did some tests having light load on the broker (5 messages / second) and noticed that while failover works (slave takes over when we stop the master broker), failback doesn't complete successfully (in about 80% of our tests), i.e. when we restart the master it fails to sync with slave and both brokers become unavailable to receive messages. We also noticed that increasing initial-replication-sync-timeout in ha-policy doesn't help.
> During failback, master reports:
> {noformat}
> 05:21:02,950 INFO [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server
> 05:21:02,965 INFO [org.apache.activemq.artemis.core.server] AMQ221000: live Message Broker is starting with configuration Broker Configuration (clustered=true,journalDirectory=/var/lib/artemis/shadowbroker/data/journal,bindingsDirectory=/var/lib/artemis/shadowbroker/data/bindings,largeMessagesDirectory=/var/lib/artemis/shadowbroker/data/largemessages,pagingDirectory=/var/lib/artemis/shadowbroker/data/paging)
> 05:21:03,456 INFO [org.apache.activemq.artemis.core.server] AMQ221055: There were too many old replicated folders upon startup, removing /var/lib/artemis/shadowbroker/data/bindings/oldreplica.43
> 05:21:03,458 INFO [org.apache.activemq.artemis.core.server] AMQ222162: Moving data directory /var/lib/artemis/shadowbroker/data/bindings to /var/lib/artemis/shadowbroker/data/bindings/oldreplica.45
> 05:21:03,460 INFO [org.apache.activemq.artemis.core.server] AMQ221055: There were too many old replicated folders upon startup, removing /var/lib/artemis/shadowbroker/data/journal/oldreplica.43
> 05:21:03,461 INFO [org.apache.activemq.artemis.core.server] AMQ222162: Moving data directory /var/lib/artemis/shadowbroker/data/journal to /var/lib/artemis/shadowbroker/data/journal/oldreplica.45
> 05:21:03,461 INFO [org.apache.activemq.artemis.core.server] AMQ221055: There were too many old replicated folders upon startup, removing /var/lib/artemis/shadowbroker/data/paging/oldreplica.37
> 05:21:03,462 INFO [org.apache.activemq.artemis.core.server] AMQ222162: Moving data directory /var/lib/artemis/shadowbroker/data/paging to /var/lib/artemis/shadowbroker/data/paging/oldreplica.39
> 05:21:03,506 INFO [org.apache.activemq.artemis.core.server] AMQ221012: Using AIO Journal
> 05:21:03,597 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE
> 05:21:03,598 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP
> 05:21:03,598 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding protocol support for: HORNETQ
> 05:21:03,599 WARN [org.apache.activemq.artemis.spi.core.protocol.MessagePersister] Cannot find persister for org.apache.activemq.artemis.core.protocol.mqtt.MQTTProtocolManagerFactory@a199e1c
> 05:21:03,599 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for: MQTT
> 05:21:03,599 WARN [org.apache.activemq.artemis.spi.core.protocol.MessagePersister] Cannot find persister for org.apache.activemq.artemis.core.protocol.openwire.OpenWireProtocolManagerFactory@a3f47b5
> 05:21:03,599 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding protocol support for: OPENWIRE
> 05:21:03,599 WARN [org.apache.activemq.artemis.spi.core.protocol.MessagePersister] Cannot find persister for org.apache.activemq.artemis.core.protocol.stomp.StompProtocolManagerFactory@1c20aa4a
> 05:21:03,600 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol support for: STOMP
> 05:21:03,704 INFO [org.apache.activemq.artemis.core.server] AMQ221109: Apache ActiveMQ Artemis Backup Server version 2.0.0 [null] started, waiting live to fail before it gets active
> 05:21:04,123 INFO [org.apache.activemq.artemis] AMQ241001: HTTP Server started at http://localhost:8161
> 05:21:04,123 INFO [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia REST API available at http://localhost:8161/jolokia
> 05:21:34,261 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: AMQ119015: The connection was disconnected because of server shutdown [code=DISCONNECTED]
> 05:21:34,300 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: AMQ119015: The connection was disconnected because of server shutdown [code=DISCONNECTED]
> 05:21:34,310 WARN [org.apache.activemq.artemis.journal] File not opened, file=null: java.lang.NullPointerException: File not opened, file=null
> at org.apache.activemq.artemis.core.io.aio.AIOSequentialFile.checkOpened(AIOSequentialFile.java:282) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.aio.AIOSequentialFile.writeDirect(AIOSequentialFile.java:196) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$LocalBufferObserver.flushBuffer(AbstractSequentialFile.java:297) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:286) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:258) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory.flush(AbstractSequentialFileFactory.java:177) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.flush(JournalImpl.java:2073) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.stop(JournalImpl.java:2221) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:246) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:183) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.replication.ReplicationEndpoint.stop(ReplicationEndpoint.java:320) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stopComponent(ActiveMQServerImpl.java:1133) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.SharedNothingBackupActivation.run(SharedNothingBackupActivation.java:252) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$ActivationThread.run(ActiveMQServerImpl.java:2722) [artemis-server-2.0.0.jar:2.0.0]
> 05:21:34,312 WARN [org.apache.activemq.artemis.journal] AMQ142027: Error on writing data! File not opened, file=null code - -1: java.lang.Exception: File not opened, file=null
> at org.apache.activemq.artemis.core.io.DummyCallback.onError(DummyCallback.java:36) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$DelegateCallback.onError(AbstractSequentialFile.java:271) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.aio.AIOSequentialFile.writeDirect(AIOSequentialFile.java:199) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$LocalBufferObserver.flushBuffer(AbstractSequentialFile.java:297) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:286) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:258) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory.flush(AbstractSequentialFileFactory.java:177) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.flush(JournalImpl.java:2073) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.stop(JournalImpl.java:2221) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:246) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:183) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.replication.ReplicationEndpoint.stop(ReplicationEndpoint.java:320) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stopComponent(ActiveMQServerImpl.java:1133) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.SharedNothingBackupActivation.run(SharedNothingBackupActivation.java:252) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$ActivationThread.run(ActiveMQServerImpl.java:2722) [artemis-server-2.0.0.jar:2.0.0]
> 05:21:34,314 WARN [org.apache.activemq.artemis.journal] AMQ142027: Error on writing data! File not opened, file=null code - -1: java.lang.Exception: File not opened, file=null
> at org.apache.activemq.artemis.core.io.DummyCallback.onError(DummyCallback.java:36) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$DelegateCallback.onError(AbstractSequentialFile.java:271) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.aio.AIOSequentialFile.writeDirect(AIOSequentialFile.java:199) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$LocalBufferObserver.flushBuffer(AbstractSequentialFile.java:297) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:286) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:258) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory.flush(AbstractSequentialFileFactory.java:177) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.flush(JournalImpl.java:2073) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.stop(JournalImpl.java:2221) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:246) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:183) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.replication.ReplicationEndpoint.stop(ReplicationEndpoint.java:320) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stopComponent(ActiveMQServerImpl.java:1133) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.SharedNothingBackupActivation.run(SharedNothingBackupActivation.java:252) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$ActivationThread.run(ActiveMQServerImpl.java:2722) [artemis-server-2.0.0.jar:2.0.0]
> 05:21:34,331 WARN [org.apache.activemq.artemis.journal] AMQ142027: Error on writing data! File not opened, file=null code - -1: java.lang.Exception: File not opened, file=null
> at org.apache.activemq.artemis.core.io.DummyCallback.onError(DummyCallback.java:36) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$DelegateCallback.onError(AbstractSequentialFile.java:271) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.aio.AIOSequentialFile.writeDirect(AIOSequentialFile.java:199) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$LocalBufferObserver.flushBuffer(AbstractSequentialFile.java:297) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:286) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:258) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory.flush(AbstractSequentialFileFactory.java:177) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.flush(JournalImpl.java:2073) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.stop(JournalImpl.java:2221) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:246) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:183) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.replication.ReplicationEndpoint.stop(ReplicationEndpoint.java:320) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stopComponent(ActiveMQServerImpl.java:1133) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.SharedNothingBackupActivation.run(SharedNothingBackupActivation.java:252) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$ActivationThread.run(ActiveMQServerImpl.java:2722) [artemis-server-2.0.0.jar:2.0.0]
> 05:21:34,332 WARN [org.apache.activemq.artemis.journal] AMQ142027: Error on writing data! File not opened, file=null code - -1: java.lang.Exception: File not opened, file=null
> at org.apache.activemq.artemis.core.io.DummyCallback.onError(DummyCallback.java:36) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$DelegateCallback.onError(AbstractSequentialFile.java:271) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.aio.AIOSequentialFile.writeDirect(AIOSequentialFile.java:199) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile$LocalBufferObserver.flushBuffer(AbstractSequentialFile.java:297) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:286) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.flush(TimedBuffer.java:258) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory.flush(AbstractSequentialFileFactory.java:177) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.flush(JournalImpl.java:2073) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.stop(JournalImpl.java:2221) [artemis-journal-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:246) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager.stop(JournalStorageManager.java:183) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.replication.ReplicationEndpoint.stop(ReplicationEndpoint.java:320) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.stopComponent(ActiveMQServerImpl.java:1133) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.SharedNothingBackupActivation.run(SharedNothingBackupActivation.java:252) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$ActivationThread.run(ActiveMQServerImpl.java:2722) [artemis-server-2.0.0.jar:2.0.0]
> 05:21:34,352 ERROR [org.apache.activemq.artemis.core.server] AMQ224000: Failure in initialisation: ActiveMQIllegalStateException[errorType=ILLEGAL_STATE message=AMQ119026: Backup Server was not yet in sync with live]
> at org.apache.activemq.artemis.core.server.impl.SharedNothingBackupActivation.run(SharedNothingBackupActivation.java:306) [artemis-server-2.0.0.jar:2.0.0]
> at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$ActivationThread.run(ActiveMQServerImpl.java:2722) [artemis-server-2.0.0.jar:2.0.0]
> 05:21:36,303 WARN [org.apache.activemq.artemis.core.server] AMQ222040: Server is stopped
> 05:21:41,414 WARN [org.apache.activemq.artemis.core.server] AMQ222040: Server is stopped
> 05:21:46,521 WARN [org.apache.activemq.artemis.core.server] AMQ222040: Server is stopped
> 05:21:51,633 WARN [org.apache.activemq.artemis.core.server] AMQ222040: Server is stopped
> 05:21:56,745 WARN [org.apache.activemq.artemis.core.server] AMQ222040: Server is stopped
> 05:22:01,860 WARN [org.apache.activemq.artemis.core.server] AMQ222040: Server is stopped
> {noformat}
> /* Note the log: _'Failure in initialisation: .. : Backup Server was not yet in sync with live]'_
> and slave reports:
> {noformat}
> 05:21:03,799 INFO [org.apache.activemq.artemis.core.server] AMQ221025: Replication: sending JournalFileImpl: (activemq-data-16.amq id = 21, recordID = 21) (size=10,485,760) to backup. AIOSequentialFile:/var/lib/artemis/shadowbroker/data/journal/activemq-data-16.amq
> 05:21:34,230 WARN [org.apache.activemq.artemis.core.server] AMQ222207: The backup server is not responding promptly introducing latency beyond the limit. Replication server being disconnected now.
> 05:21:34,275 INFO [org.apache.activemq.artemis.core.server] AMQ221002: Apache ActiveMQ Artemis Message Broker version 2.0.0 [414c15f2-20ee-11e7-b9f1-525400ec0962] stopped, uptime 5 minutes
> 05:21:34,275 INFO [org.apache.activemq.artemis.core.server] AMQ221039: Restarting as Replicating backup server after live restart
> 05:21:34,276 INFO [org.apache.activemq.artemis.core.server] AMQ221000: backup Message Broker is starting with configuration Broker Configuration (clustered=true,journalDirectory=/var/lib/artemis/shadowbroker/data/journal,bindingsDirectory=/var/lib/artemis/shadowbroker/data/bindings,largeMessagesDirectory=/var/lib/artemis/shadowbroker/data/largemessages,pagingDirectory=/var/lib/artemis/shadowbroker/data/paging)
> 05:21:34,278 INFO [org.apache.activemq.artemis.core.server] AMQ222190: Deleting old data directory /var/lib/artemis/shadowbroker/data/bindings as the max folders is set to 0
> 05:21:34,280 INFO [org.apache.activemq.artemis.core.server] AMQ222190: Deleting old data directory /var/lib/artemis/shadowbroker/data/journal as the max folders is set to 0
> 05:21:34,283 INFO [org.apache.activemq.artemis.core.server] AMQ222190: Deleting old data directory /var/lib/artemis/shadowbroker/data/paging as the max folders is set to 0
> 05:21:34,283 INFO [org.apache.activemq.artemis.core.server] AMQ221012: Using AIO Journal
> 05:21:34,285 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE
> 05:21:34,289 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP
> 05:21:34,289 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding protocol support for: HORNETQ
> 05:21:34,290 WARN [org.apache.activemq.artemis.spi.core.protocol.MessagePersister] Cannot find persister for org.apache.activemq.artemis.core.protocol.mqtt.MQTTProtocolManagerFactory@581792eb
> 05:21:34,290 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for: MQTT
> 05:21:34,291 WARN [org.apache.activemq.artemis.spi.core.protocol.MessagePersister] Cannot find persister for org.apache.activemq.artemis.core.protocol.openwire.OpenWireProtocolManagerFactory@2fb8fb3c
> 05:21:34,291 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding protocol support for: OPENWIRE
> 05:21:34,291 WARN [org.apache.activemq.artemis.spi.core.protocol.MessagePersister] Cannot find persister for org.apache.activemq.artemis.core.protocol.stomp.StompProtocolManagerFactory@2b09083f
> 05:21:34,291 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol support for: STOMP
> {noformat}
> /* Note the log: _'The backup server is not responding promptly introducing latency beyond the limit'_
> master has the following ha-policy configuration:
> {code:xml}
> <ha-policy>
> <replication>
> <master>
> <check-for-live-server>true</check-for-live-server>
> <initial-replication-sync-timeout>90000</initial-replication-sync-timeout>
> </master>
> </replication>
> </ha-policy>
> {code}
> while slave has:
> {code:xml}
> <ha-policy>
> <replication>
> <slave>
> <allow-failback>true</allow-failback>
> <initial-replication-sync-timeout>90000</initial-replication-sync-timeout>
> </slave>
> </replication>
> </ha-policy>
> {code}
> For running the tests, we send messages using the artemis producer - command:
> {noformat}
> ./apache-artemis-2.0.0/bin/artemis producer --url "tcp://xxx:61616?ha=true&retryInterval=1000&retryIntervalMultiplier=1.0&reconnectAttempts=-1" --destination queue://test-load --message-count 60000 --user xxx --password xxx --sleep 100 --text-size 4000
> {noformat}
> and consume messages with the artemis consumer - command:
> {noformat}
> ./apache-artemis-2.0.0/bin/artemis consumer --url "tcp://xxx:61616?ha=true&retryInterval=1000&retryIntervalMultiplier=1.0&reconnectAttempts=-1" --destination queue://test-load --threads 5 --message-count 60000 --user xxx --password xxx
> {noformat}
> Is this an existing bug on artemis? Please let us know if we can provide some other info about the issue.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)