Merge pull request #103 from ml054/v5.4

tuning flacky test
ravendb · Aug 26, 2024 · ddaddba · ddaddba
2 parents 4a36a56 + 9423a41
commit ddaddba
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/test/java/net/ravendb/client/test/server/replication/PullReplicationTest.java b/src/test/java/net/ravendb/client/test/server/replication/PullReplicationTest.java
@@ -185,6 +185,7 @@ public void updatePullReplicationOnSink() throws Exception {
                     waitForDocumentToReplicate(sink, User.class,"hub1/1", timeout);
 
                     PullReplicationAsSink pull = new PullReplicationAsSink(hub2.getDatabase(), "ConnectionString2-" + sink.getDatabase(), definitionName2);
+                    pull.setUrl(sink.getUrls()[0]);
                     pull.setTaskId(pullTasks.get(0).getTaskId());
 
                     addWatcherToReplicationTopology(sink, pull, hub2.getUrls());
@@ -277,6 +278,7 @@ public void disablePullReplicationOnSink() throws Exception {
 
                 PullReplicationAsSink pull = new PullReplicationAsSink(hub.getDatabase(), "ConnectionString-" + sink.getDatabase(), definitionName);
                 pull.setDisabled(true);
+                pull.setUrl(sink.getUrls()[0]);
                 pull.setTaskId(pullTasks.get(0).getTaskId());
 
                 addWatcherToReplicationTopology(sink, pull, hub.getUrls());
@@ -386,6 +388,7 @@ public List<ModifyOngoingTaskResult> setupPullReplication(String remoteName, Doc
 
         for (DocumentStore store : hub) {
             PullReplicationAsSink pull = new PullReplicationAsSink(store.getDatabase(), "ConnectionString-" + store.getDatabase(), remoteName);
+            pull.setUrl(sink.getUrls()[0]);
             modifyReplicationDestination(pull);
             resList.add(addWatcherToReplicationTopology(sink, pull, store.getUrls()));
         }