Skip to content

Commit

Permalink
Decrease Consistency-IT timeout
Browse files Browse the repository at this point in the history
Signed-off-by: David Schwilk <david.schwilk@bosch.io>
  • Loading branch information
DerSchwilk committed Mar 14, 2022
1 parent c7e1bd8 commit 4227b4a
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -175,7 +175,7 @@ private ActorRef createSearchUpdaterShardRegion(final ActorRef changeQueue,
final ActorRef pubSub,
final UpdaterConfig config) {

ChangeQueueActor.createSource(changeQueue, true, java.time.Duration.ofSeconds(3));
ChangeQueueActor.createSource(changeQueue, true, java.time.Duration.ofSeconds(1));
final var updaterProps = ThingUpdater.props(pubSub, changeQueue, config);
final var updater = actorSystem.actorOf(updaterProps, THING_ID.toString() + Math.random());

Expand All @@ -194,7 +194,7 @@ public void assertConsistencyInCaseOfConflict() {
.newObjectBuilder().set("char", EXPECTED_CHAR).set("number", EXPECTED_NUMBER).build())));
probe.send(updater2, getThingEvent(ThingsModelFactory.newAttributes(JsonFactory
.newObjectBuilder().set("number", EXPECTED_NUMBER).set("char", EXPECTED_CHAR).build())));
assertSearchPersisted(Duration.ofSeconds(10));
assertSearchPersisted(Duration.ofSeconds(5));
}

private static ThingEvent<?> getThingEvent(final Attributes attributes) {
Expand Down

0 comments on commit 4227b4a

Please sign in to comment.