From 65d497fd15e32cd423ae64d13e9b6d1aadc8446f Mon Sep 17 00:00:00 2001 From: allanmckenzie Date: Wed, 10 Apr 2024 10:34:34 +0100 Subject: [PATCH 1/3] Add integration test for SendEventToEventIndexer JMX command --- .../example/cakeshop/it/SendSingleEventToEventListenerIT.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java index 33bfbca8..1d06f317 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java @@ -12,7 +12,6 @@ import static uk.gov.justice.services.test.utils.common.host.TestHostProvider.getHost; import org.junit.Before; -import org.junit.Ignore; import org.junit.Test; import uk.gov.justice.services.eventsourcing.repository.jdbc.event.PublishedEvent; import uk.gov.justice.services.example.cakeshop.it.helpers.DatabaseManager; @@ -31,7 +30,6 @@ import javax.sql.DataSource; -@Ignore("Temporarily ignoring until the command is implemented in event-store. 10 April 2024") public class SendSingleEventToEventListenerIT { private static final String HOST = getHost(); From fbe2cab6196fcf3701c0ca45b747f3772c0ce840 Mon Sep 17 00:00:00 2001 From: santhosh Date: Fri, 12 Apr 2024 09:26:35 +0100 Subject: [PATCH 2/3] Fix ReplayToEventIndexer IT --- CHANGELOG.md | 3 +- ...eEventIndexerInterceptorChainProvider.java | 27 +++++++++++++++++ ...ntIndexerInterceptorChainProviderTest.java | 29 +++++++++++++++++++ .../cakeshop/it/CatchupPerformanceIT.java | 8 ++--- .../example/cakeshop/it/EventHealingIT.java | 16 ++++++---- .../cakeshop/it/EventValidationIT.java | 3 +- .../it/SendSingleEventToEventIndexerIT.java | 2 -- .../it/helpers/ProcessedEventFinder.java | 16 ++++++++++ .../wildfly-config/standalone-single.xml | 2 +- pom.xml | 2 +- 10 files changed, 93 insertions(+), 15 deletions(-) create mode 100644 example-context/example-service/example-event/example-event-indexer/src/main/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProvider.java create mode 100644 example-context/example-service/example-event/example-event-indexer/src/test/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProviderTest.java diff --git a/CHANGELOG.md b/CHANGELOG.md index ed528372..df0cabff 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -10,7 +10,8 @@ on [Keep a CHANGELOG](http://keepachangelog.com/). This project adheres to - Publishing of events no longer use a trigger on the event_log table - Filestore now does hard delete when deleting files rather than just marking as deleted - Fix hibernate incompatibility issue while running ITs in embedded wildfly -- Fix classDefNotFoundError logged by wildfly-maven-plugin while shutting down embedded wildfly server +- Fix classDefNotFoundError logged by wildfly-maven-plugin while shutting down embedded wildfly server +- Add ITs for validating REPLAY_EVENT_TO_EVENT_LISTENER and REPLAY_EVENT_TO_EVENT_INDEXER command processing ## [7.0.0] - 2021-09-27 ### Changed diff --git a/example-context/example-service/example-event/example-event-indexer/src/main/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProvider.java b/example-context/example-service/example-event/example-event-indexer/src/main/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProvider.java new file mode 100644 index 00000000..7e168d80 --- /dev/null +++ b/example-context/example-service/example-event/example-event-indexer/src/main/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProvider.java @@ -0,0 +1,27 @@ +package uk.gov.justice.services.example.cakeshop.provider; + +import uk.gov.justice.services.core.interceptor.InterceptorChainEntry; +import uk.gov.justice.services.core.interceptor.InterceptorChainEntryProvider; +import uk.gov.justice.services.event.source.subscriptions.interceptors.SubscriptionEventInterceptor; + +import java.util.ArrayList; +import java.util.List; + +public class ExampleEventIndexerInterceptorChainProvider implements InterceptorChainEntryProvider { + + private final List interceptorChainEntries = new ArrayList(); + + public ExampleEventIndexerInterceptorChainProvider() { + interceptorChainEntries.add(new InterceptorChainEntry(1000, SubscriptionEventInterceptor.class)); + } + + @Override + public String component() { + return "EVENT_INDEXER"; + } + + @Override + public List interceptorChainTypes() { + return interceptorChainEntries; + } +} diff --git a/example-context/example-service/example-event/example-event-indexer/src/test/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProviderTest.java b/example-context/example-service/example-event/example-event-indexer/src/test/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProviderTest.java new file mode 100644 index 00000000..df70dd11 --- /dev/null +++ b/example-context/example-service/example-event/example-event-indexer/src/test/java/uk/gov/justice/services/example/cakeshop/provider/ExampleEventIndexerInterceptorChainProviderTest.java @@ -0,0 +1,29 @@ +package uk.gov.justice.services.example.cakeshop.provider; + +import org.junit.Test; +import uk.gov.justice.services.core.interceptor.InterceptorChainEntry; + +import java.util.List; + +import static org.hamcrest.CoreMatchers.is; +import static org.hamcrest.MatcherAssert.assertThat; + +public class ExampleEventIndexerInterceptorChainProviderTest { + + @Test + public void shouldCreateInterceptorChainEntriesWithSubscriptionEventInterceptor() { + + final List interceptorChainEntries = new ExampleEventIndexerInterceptorChainProvider().interceptorChainTypes(); + + assertThat(interceptorChainEntries.size(), is(1)); + + final InterceptorChainEntry interceptorChainEntry = interceptorChainEntries.get(0); + assertThat(interceptorChainEntry.getInterceptorType().getName(), is("uk.gov.justice.services.event.source.subscriptions.interceptors.SubscriptionEventInterceptor")); + assertThat(interceptorChainEntry.getPriority(), is(1000)); + } + + @Test + public void shouldReturnComponentName() { + assertThat(new ExampleEventIndexerInterceptorChainProvider().component(), is("EVENT_INDEXER")); + } +} \ No newline at end of file diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CatchupPerformanceIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CatchupPerformanceIT.java index 22075318..68998eef 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CatchupPerformanceIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CatchupPerformanceIT.java @@ -95,7 +95,8 @@ public void shouldReplayAndFindRecipesInViewStore() throws Exception { System.out.println("Waiting for events to publish..."); final Optional processedEventCount = longPoller.pollUntilFound(() -> { - final int eventCount = processedEventCounter.countProcessedEvents(); + final int eventCount = processedEventCounter.countProcessedEventsForEventListener(); + System.out.printf("Polling processed_event table. Expected events count: %d, found: %d", totalEvents, eventCount); if (eventCount == totalEvents) { return of(eventCount); } @@ -112,9 +113,8 @@ public void shouldReplayAndFindRecipesInViewStore() throws Exception { runCatchup(); final Optional numberOfReplayedEvents = longPoller.pollUntilFound(() -> { - final int eventCount = processedEventCounter.countProcessedEvents(); - System.out.println(format("%s events in processed_event table", eventCount)); - + final int eventCount = processedEventCounter.countProcessedEventsForEventListener(); + System.out.printf("Polling processed_event table. Expected events count: %d, found: %d", totalEvents, eventCount); if (eventCount == totalEvents) { return of(eventCount); } diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventHealingIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventHealingIT.java index 6ebe6d13..678a9e76 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventHealingIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventHealingIT.java @@ -9,6 +9,7 @@ import static javax.ws.rs.core.Response.Status.ACCEPTED; import static org.hamcrest.CoreMatchers.is; import static org.hamcrest.MatcherAssert.assertThat; +import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; import static uk.gov.justice.services.eventstore.management.commands.EventCatchupCommand.CATCHUP; import static uk.gov.justice.services.example.cakeshop.it.params.CakeShopMediaTypes.ADD_RECIPE_MEDIA_TYPE; @@ -71,7 +72,7 @@ public class EventHealingIT { private final DatabaseCleaner databaseCleaner = new DatabaseCleaner(); private final SequenceSetter sequenceSetter = new SequenceSetter(); - private final Poller poller = new Poller(); + private final Poller poller = new Poller(50, 1000); private Client client; @@ -116,8 +117,9 @@ public void shouldReplayAndFindRecipesInViewStore() throws Exception { assertThat(response.getStatus(), isStatus(ACCEPTED)); } - poller.pollUntilFound(() -> { - final int eventCount = processedEventFinder.countProcessedEvents(); + final Optional result = poller.pollUntilFound(() -> { + final int eventCount = processedEventFinder.countProcessedEventsForEventListener(); + System.out.printf("Polling processed_event table. Expected events count: %d, found: %d", numberOfRecipes, eventCount); if (eventCount == numberOfRecipes) { return of(eventCount); } @@ -125,6 +127,8 @@ public void shouldReplayAndFindRecipesInViewStore() throws Exception { return empty(); }); + assertTrue(result.isPresent()); + removeRecipesFromViewStore(3, findRecipeIdForEventNumber(3)); removeRecipesFromViewStore(5, findRecipeIdForEventNumber(5)); removeRecipesFromViewStore(6, findRecipeIdForEventNumber(6)); @@ -133,7 +137,8 @@ public void shouldReplayAndFindRecipesInViewStore() throws Exception { runCatchup(); final Optional numberOfEventsInProcessedEventTable = poller.pollUntilFound(() -> { - final int eventCount = processedEventFinder.countProcessedEvents(); + final int eventCount = processedEventFinder.countProcessedEventsForEventListener(); + System.out.printf("Polling processed_event table. Expected events count: %d, found: %d", numberOfRecipes, eventCount); if (eventCount == numberOfRecipes) { return of(eventCount); } @@ -189,7 +194,8 @@ private void cleanViewstoreTables() { "recipe", "cake", "cake_order", - "processed_event" + "processed_event", + "stream_status" ); databaseCleaner.cleanStreamBufferTable(contextName); diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java index 88b9f64c..abe0d426 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java @@ -60,7 +60,7 @@ public class EventValidationIT { private final TestSystemCommanderClientFactory systemCommanderClientFactory = new TestSystemCommanderClientFactory(); - private final Poller poller = new Poller(); + private final Poller poller = new Poller(100, 1000); private final BatchEventInserter batchEventInserter = new BatchEventInserter(eventStoreDataSource, BATCH_INSERT_SIZE); private PublishedEventCounter publishedEventCounter = new PublishedEventCounter(eventStoreDataSource); @@ -134,6 +134,7 @@ public void shouldFailIfAnyEventsAreInvalid() throws Exception { private void waitForEventsToPublish(final int totalEvents) { final Optional publishedEventCount = poller.pollUntilFound(() -> { final int eventCount = publishedEventCounter.countPublishedEvents(); + System.out.printf("Polling published_event table. Expected events count: %d, found: %d", totalEvents, eventCount); if (eventCount == totalEvents) { return of(eventCount); } diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java index 04671bce..7a3ed156 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java @@ -29,10 +29,8 @@ import javax.sql.DataSource; import org.junit.Before; -import org.junit.Ignore; import org.junit.Test; -@Ignore("Temporarily ignoring until the command is implemented in event-store. 10 April 2024") public class SendSingleEventToEventIndexerIT { private static final String HOST = getHost(); diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/helpers/ProcessedEventFinder.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/helpers/ProcessedEventFinder.java index 2435fa6a..d636ec8b 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/helpers/ProcessedEventFinder.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/helpers/ProcessedEventFinder.java @@ -78,4 +78,20 @@ public int countProcessedEvents() { throw new RuntimeException("Failed to run query '" + sql + "' against the view store", e); } } + + public int countProcessedEventsForEventListener() { + + final String sql = "SELECT COUNT (*) FROM processed_event where component = 'EVENT_LISTENER'"; + + try(final Connection connection = viewStoreDataSource.getConnection(); + final PreparedStatement preparedStatement = connection.prepareStatement(sql); + final ResultSet resultSet = preparedStatement.executeQuery()) { + + resultSet.next(); + + return resultSet.getInt(1); + } catch (final SQLException e) { + throw new RuntimeException("Failed to run query '" + sql + "' against the view store", e); + } + } } diff --git a/example-context/example-service/example-it/src/test/resources/wildfly-config/standalone-single.xml b/example-context/example-service/example-it/src/test/resources/wildfly-config/standalone-single.xml index 323b7976..ded228d2 100644 --- a/example-context/example-service/example-it/src/test/resources/wildfly-config/standalone-single.xml +++ b/example-context/example-service/example-it/src/test/resources/wildfly-config/standalone-single.xml @@ -391,7 +391,7 @@ postgres 3 - 3 + 6 true diff --git a/pom.xml b/pom.xml index 8816fd58..5debca5d 100644 --- a/pom.xml +++ b/pom.xml @@ -33,7 +33,7 @@ 8.0.4 8.10.0-M2 - 8.10.0-M3 + 8.10.0-M4-SNAPSHOT From 366654facae3315ff9bcc011031bbc32c6db43fd Mon Sep 17 00:00:00 2001 From: santhosh Date: Fri, 12 Apr 2024 13:46:04 +0100 Subject: [PATCH 3/3] Enhance poller logging --- .../services/example/cakeshop/it/CakeShopManyUpdatesIT.java | 1 + .../services/example/cakeshop/it/EventValidationIT.java | 1 + .../gov/justice/services/example/cakeshop/it/RebuildIT.java | 1 + .../example/cakeshop/it/SendSingleEventToEventIndexerIT.java | 5 ++++- .../cakeshop/it/SendSingleEventToEventListenerIT.java | 5 ++++- .../gov/justice/services/example/cakeshop/it/SuspendIT.java | 4 ++++ pom.xml | 4 ++-- 7 files changed, 17 insertions(+), 4 deletions(-) diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CakeShopManyUpdatesIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CakeShopManyUpdatesIT.java index 27a33dd7..1da886f9 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CakeShopManyUpdatesIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CakeShopManyUpdatesIT.java @@ -101,6 +101,7 @@ public void shouldSuccessfullyProcessManyUpdatesToSameRecipeId() throws Exceptio .put(eventFactory.renameRecipeEntity("Final Name")); new Poller().pollUntilFound(() -> { + System.out.printf("Polling for query response body to contain 'Final Name' for recipeId: %s", recipeId); if (querier.queryForRecipe(recipeId).body().contains("Final Name")) { return of(true); } diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java index abe0d426..f710ec10 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/EventValidationIT.java @@ -230,6 +230,7 @@ private List getEventIds() throws Exception { private Optional commandNoLongerInProgress(final SystemCommanderMBean systemCommanderMBean, final UUID commandId) { final SystemCommandStatus systemCommandStatus = systemCommanderMBean.getCommandStatus(commandId); + System.out.printf("Polling for command state to be COMMAND_COMPLETE||COMMAND_FAILED for commandId: %s", commandId); final CommandState commandState = systemCommandStatus.getCommandState(); if (commandState == COMMAND_COMPLETE || commandState == COMMAND_FAILED) { diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/RebuildIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/RebuildIT.java index d90a492f..10915d06 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/RebuildIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/RebuildIT.java @@ -124,6 +124,7 @@ private List getPublishedEvents(final long startNumber) { final List events = doGetPublishedEvents(); + System.out.printf("Polling published_event table. Expected events count: %d, found: %d", 3, events.size()); if (events.size() == 3) { final Optional eventNumber = events.get(0).getEventNumber(); if(eventNumber.isPresent()) { diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java index 7a3ed156..16a0d6fb 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventIndexerIT.java @@ -75,7 +75,10 @@ public void shouldReplaySingleEventToEventIndexerUsingTheReplayEventToEventIndex } final Optional processedEvent = poller.pollUntilFound( - () -> processedEventFinder.findProcessedEvent(publishedEvent.getId()) + () -> { + System.out.printf("Polling processed_event table for existence of event id: %s", publishedEvent.getId()); + return processedEventFinder.findProcessedEvent(publishedEvent.getId()); + } ); if (processedEvent.isPresent()) { diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java index 1d06f317..aceb61cc 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SendSingleEventToEventListenerIT.java @@ -74,7 +74,10 @@ public void shouldReplaySingleEventToEventListenerUsingTheReplayEventToEventList } final Optional processedEvent = poller.pollUntilFound( - () -> processedEventFinder.findProcessedEvent(publishedEvent.getId()) + () -> { + System.out.printf("Polling processed_event table for existence of event id: %s", publishedEvent.getId()); + return processedEventFinder.findProcessedEvent(publishedEvent.getId()); + } ); if (processedEvent.isPresent()) { diff --git a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SuspendIT.java b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SuspendIT.java index 80a4c656..30d2cbd6 100644 --- a/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SuspendIT.java +++ b/example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/SuspendIT.java @@ -94,6 +94,7 @@ public void cleanup() throws Exception { final UUID commandId = systemCommanderMBean.call(UNSUSPEND); final Optional unsuspendStatus = poller.pollUntilFound(() -> { + System.out.printf("Polling for command state to be COMMAND_COMPLETE for commandId: %s", commandId); final SystemCommandStatus commandStatus = systemCommanderMBean.getCommandStatus(commandId); if (commandStatus.getCommandState() == COMMAND_COMPLETE) { return of(commandStatus); @@ -121,6 +122,7 @@ public void shouldNotReturnRecipesAfterSuspending() throws Exception { final UUID commandId = systemCommanderMBean.call(SUSPEND); final Optional suspendStatus = poller.pollUntilFound(() -> { + System.out.printf("Polling for command state to be COMMAND_COMPLETE for commandId: %s", commandId); final SystemCommandStatus commandStatus = systemCommanderMBean.getCommandStatus(commandId); if (commandStatus.getCommandState() == COMMAND_COMPLETE) { return of(commandStatus); @@ -160,6 +162,7 @@ public void shouldQueryForRecipesAfterUnShuttering() throws Exception { final UUID suspendCommandId = systemCommanderMBean.call(SUSPEND); final Optional suspendStatus = poller.pollUntilFound(() -> { + System.out.printf("Polling for command state to be COMMAND_COMPLETE for commandId: %s", suspendCommandId); final SystemCommandStatus commandStatus = systemCommanderMBean.getCommandStatus(suspendCommandId); if (commandStatus.getCommandState() == COMMAND_COMPLETE) { return of(commandStatus); @@ -186,6 +189,7 @@ public void shouldQueryForRecipesAfterUnShuttering() throws Exception { final UUID unsuspendCommandId = systemCommanderMBean.call(UNSUSPEND); final Optional unsuspendStatus = poller.pollUntilFound(() -> { + System.out.printf("Polling for command state to be COMMAND_COMPLETE for commandId: %s", unsuspendCommandId); final SystemCommandStatus commandStatus = systemCommanderMBean.getCommandStatus(unsuspendCommandId); if (commandStatus.getCommandState() == COMMAND_COMPLETE) { return of(commandStatus); diff --git a/pom.xml b/pom.xml index 5debca5d..54de795a 100644 --- a/pom.xml +++ b/pom.xml @@ -31,9 +31,9 @@ cake-shop - 8.0.4 + 8.0.7 8.10.0-M2 - 8.10.0-M4-SNAPSHOT + 8.10.0-M4