Skip to content

Commit 86be27f

Browse files
gnodetclaude
andcommitted
Fix ConsumeDataIT to use deleteAll for shared ZooKeeper cleanup
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent ae70ca7 commit 86be27f

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

  • components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration

components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/integration/ConsumeDataIT.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ public void shouldAwaitCreationAndGetDataNotification() throws Exception {
6464
updateNode(10);
6565

6666
delay(500);
67-
client.delete("/camel");
67+
client.deleteAll("/camel");
6868

6969
MockEndpoint.assertIsSatisfied(30, TimeUnit.SECONDS);
7070

@@ -90,15 +90,15 @@ public void deletionOfAwaitedNodeCausesNoFailure() throws Exception {
9090
delay(500);
9191

9292
// by now we are back waiting for a change so delete the node
93-
client.delete("/camel");
93+
client.deleteAll("/camel");
9494

9595
// recreate and update a number of times.
9696
createCamelNode();
9797
updateNode(10);
9898

9999
MockEndpoint.assertIsSatisfied(30, TimeUnit.SECONDS);
100100

101-
client.delete("/camel");
101+
client.deleteAll("/camel");
102102
}
103103

104104
private void updateNode(int times) throws Exception {

0 commit comments

Comments
 (0)