(camel-quarkus) branch main updated: Wait for the MongoDB replica set primary before running container init commands

[jamesnetherton]

This is an automated email from the ASF dual-hosted git repository.

jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new 5e4f9f13d6 Wait for the MongoDB replica set primary before running 
container init commands
5e4f9f13d6 is described below

commit 5e4f9f13d694d6e771399fdeac48f9637bd346a8
Author: James Netherton <jamesnether...@users.noreply.github.com>
AuthorDate: Tue Sep 22 15:28:40 2026 +0100

    Wait for the MongoDB replica set primary before running container init 
commands
---
 .../debezium/mongodb/src/test/resources/initMongodb.txt                 | 2 ++
 integration-tests-support/mongodb/src/main/resources/initMongodb.txt    | 2 ++
 2 files changed, 4 insertions(+)

diff --git 
a/integration-test-groups/debezium/mongodb/src/test/resources/initMongodb.txt 
b/integration-test-groups/debezium/mongodb/src/test/resources/initMongodb.txt
index 8eb79b2d56..1f199f7164 100644
--- 
a/integration-test-groups/debezium/mongodb/src/test/resources/initMongodb.txt
+++ 
b/integration-test-groups/debezium/mongodb/src/test/resources/initMongodb.txt
@@ -5,6 +5,8 @@ rs.initiate( {
         'host' : '%container-host%',
         'priority': 2}]
     });
+for (var i = 0; i < 600 && !db.hello().isWritablePrimary; i++) { sleep(100); }
+if (!db.hello().isWritablePrimary) { throw new Error('Replica set member did 
not become primary within 60 seconds'); }
 
 db.getSiblingDB('admin').runCommand( {
     createRole: 'listDatabases',
diff --git 
a/integration-tests-support/mongodb/src/main/resources/initMongodb.txt 
b/integration-tests-support/mongodb/src/main/resources/initMongodb.txt
index 4d128a0363..bff2157cb4 100644
--- a/integration-tests-support/mongodb/src/main/resources/initMongodb.txt
+++ b/integration-tests-support/mongodb/src/main/resources/initMongodb.txt
@@ -5,6 +5,8 @@ rs.initiate( {
         'host' : 'mongodb_private:27017',
         'priority': 2}]
     });
+for (var i = 0; i < 600 && !db.hello().isWritablePrimary; i++) { sleep(100); }
+if (!db.hello().isWritablePrimary) { throw new Error('Replica set member did 
not become primary within 60 seconds'); }
 
 db.getSiblingDB('admin').runCommand( {
     createRole: 'listDatabases',