From 2b95a6954d1a76fbdb4733283b86df30ce70d4d0 Mon Sep 17 00:00:00 2001
From: Valery Kharseko <vharseko@3a-systems.ru>
Date: Wed, 08 Jul 2026 17:13:43 +0000
Subject: [PATCH] Enable the remaining slow-group tests in the default build (#702)
---
opendj-server-legacy/src/main/java/org/opends/server/replication/server/MessageHandler.java | 19 +++++++++++++++++++
1 files changed, 19 insertions(+), 0 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/replication/server/MessageHandler.java b/opendj-server-legacy/src/main/java/org/opends/server/replication/server/MessageHandler.java
index 6b3f1e8..6e280e8 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/replication/server/MessageHandler.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/replication/server/MessageHandler.java
@@ -13,6 +13,7 @@
*
* Copyright 2009-2010 Sun Microsystems, Inc.
* Portions Copyright 2011-2016 ForgeRock AS.
+ * Portions Copyright 2026 3A Systems, LLC
*/
package org.opends.server.replication.server;
@@ -207,6 +208,24 @@
}
/**
+ * Indicates whether this handler is served from the in-memory message
+ * queue, i.e. it is done catching up with the changelog DB.
+ * <p>
+ * Package private: allows tests to wait until a freshly connected peer
+ * will receive published updates through the in-memory queue path rather
+ * than re-read from the changelog DB.
+ *
+ * @return true when this handler follows the in-memory message queue
+ */
+ boolean isFollowing()
+ {
+ synchronized (msgQueue)
+ {
+ return following;
+ }
+ }
+
+ /**
* Retrieves the name of this monitor provider. It should be unique among all
* monitor providers, including all instances of the same monitor provider.
*
--
Gitblit v1.10.0