Skip to content

Commit

Permalink
Update framework to 6.0.12
Browse files Browse the repository at this point in the history
  • Loading branch information
amckenzie committed Sep 8, 2019
1 parent cf84b16 commit cfb2fd8
Show file tree
Hide file tree
Showing 3 changed files with 22 additions and 9 deletions.
9 changes: 8 additions & 1 deletion example-context/example-service/example-it/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -431,8 +431,15 @@
</configuration>
</execution>
<execution>
<id>stop-server</id>
<id>undeploy</id>
<phase>post-integration-test</phase>
<goals>
<goal>undeploy</goal>
</goals>
</execution>
<execution>
<id>stop-server</id>
<phase>install</phase>
<goals>
<goal>shutdown</goal>
</goals>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ public void shouldRenumberTheEventLogTableAndRebuldPublishedEvents() throws Exce
commandSender.addRecipe(randomUUID().toString(), "cake 2");
commandSender.addRecipe(randomUUID().toString(), "cake 3");

final List<PublishedEvent> publishedEvents = getPublishedEvents();
final List<PublishedEvent> publishedEvents = getPublishedEvents(startNumber);

assertThat(publishedEvents.size(), is(3));
assertThat(publishedEvents.get(0).getEventNumber(), is(of(startNumber)));
Expand All @@ -89,14 +89,15 @@ public void shouldRenumberTheEventLogTableAndRebuldPublishedEvents() throws Exce

invokeRebuild();

final List<PublishedEvent> rebuiltEvents = getPublishedEvents();
final long newStartNumber = 1L;
final List<PublishedEvent> rebuiltEvents = getPublishedEvents(newStartNumber);
assertThat(rebuiltEvents.size(), is(3));

final List<UUID> rebuiltEventIds = rebuiltEvents.stream()
.map(Event::getId)
.collect(toList());

assertThat(rebuiltEvents.get(0).getEventNumber(), is(of(1L)));
assertThat(rebuiltEvents.get(0).getEventNumber(), is(of(newStartNumber)));

assertThat(rebuiltEventIds, hasItem(eventIds.get(0)));
assertThat(rebuiltEventIds, hasItem(eventIds.get(1)));
Expand All @@ -117,14 +118,19 @@ private void invokeRebuild() throws Exception {
}
}

private List<PublishedEvent> getPublishedEvents() {
private List<PublishedEvent> getPublishedEvents(final long startNumber) {

final Optional<List<PublishedEvent>> publishedEvents = poller.pollUntilFound(() -> {

final List<PublishedEvent> events = doGetPublishedEvents();

if (events.size() == 3) {
return of(events);
final Optional<Long> eventNumber = events.get(0).getEventNumber();
if(eventNumber.isPresent()) {
if (eventNumber.get() == startNumber) {
return of(events);
}
}
}

return empty();
Expand Down
6 changes: 3 additions & 3 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@
<cpp.repo.name>cake-shop</cpp.repo.name>

<framework-api.version>4.0.1</framework-api.version>
<framework.version>6.0.11</framework.version>
<event-store.version>2.0.13</event-store.version>
<framework-generators.version>2.0.8</framework-generators.version>
<framework.version>6.0.12</framework.version>
<event-store.version>2.0.14</event-store.version>
<framework-generators.version>2.0.9</framework-generators.version>
<file.service.version>1.17.11</file.service.version>

<common-bom.version>2.4.0</common-bom.version>
Expand Down

0 comments on commit cfb2fd8

Please sign in to comment.