[
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)
