activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Justin Bertram (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-1161) HA Replication Failback Failure
Date Fri, 12 May 2017 15:37:04 GMT

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

Justin Bertram commented on ARTEMIS-1161:
-----------------------------------------

Can you try [2.1.0|https://repository.apache.org/content/repositories/orgapacheactivemq-1133/org/apache/activemq/apache-artemis/2.1.0/]?
It's not officially released, but it's up for a vote as I write this. Some work has been done
to replication since 2.0.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)

Mime
View raw message