You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Andrei Bercu (JIRA)" <ji...@apache.org> on 2017/05/12 14:11:04 UTC
[jira] [Created] (ARTEMIS-1161) HA Replication Failback Failure
Andrei Bercu created ARTEMIS-1161:
-------------------------------------
Summary: 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)