diff --git a/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/subscription/ResourceModifiedMessagePersistenceSvcImpl.java b/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/subscription/ResourceModifiedMessagePersistenceSvcImpl.java
index 4f29193f5e9..930f2e7c8a3 100644
--- a/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/subscription/ResourceModifiedMessagePersistenceSvcImpl.java
+++ b/hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/subscription/ResourceModifiedMessagePersistenceSvcImpl.java
@@ -47,7 +47,6 @@ import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 
 import java.util.Date;
-import java.util.List;
 import java.util.Optional;
 
 import static ca.uhn.fhir.jpa.model.entity.PersistedResourceModifiedMessageEntityPK.with;
diff --git a/hapi-fhir-jpaserver-subscription/src/main/java/ca/uhn/fhir/jpa/subscription/async/AsyncResourceModifiedSubmitterSvc.java b/hapi-fhir-jpaserver-subscription/src/main/java/ca/uhn/fhir/jpa/subscription/async/AsyncResourceModifiedSubmitterSvc.java
index f537a8f98cb..58e7ba6acb6 100644
--- a/hapi-fhir-jpaserver-subscription/src/main/java/ca/uhn/fhir/jpa/subscription/async/AsyncResourceModifiedSubmitterSvc.java
+++ b/hapi-fhir-jpaserver-subscription/src/main/java/ca/uhn/fhir/jpa/subscription/async/AsyncResourceModifiedSubmitterSvc.java
@@ -54,16 +54,18 @@ public class AsyncResourceModifiedSubmitterSvc {
 		int limit = getLimit();
 		do {
 			// we always take the 0th page, because we're deleting the elements as we process them
-			Page<IPersistedResourceModifiedMessage> persistedResourceModifiedMsgsPage = myResourceModifiedMessagePersistenceSvc.findAllOrderedByCreatedTime(
-				PageRequest.of(0, limit));
+			Page<IPersistedResourceModifiedMessage> persistedResourceModifiedMsgsPage =
+					myResourceModifiedMessagePersistenceSvc.findAllOrderedByCreatedTime(PageRequest.of(0, limit));
 			ourLog.debug(
-				"Attempting to submit {} resources to consumer channel.", persistedResourceModifiedMsgsPage.getTotalElements());
+					"Attempting to submit {} resources to consumer channel.",
+					persistedResourceModifiedMsgsPage.getTotalElements());
 
 			hasMoreToFetch = persistedResourceModifiedMsgsPage.hasNext();
 
-			for (IPersistedResourceModifiedMessage persistedResourceModifiedMessage : persistedResourceModifiedMsgsPage) {
-				boolean wasProcessed =
-					myResourceModifiedConsumer.submitPersisedResourceModifiedMessage(persistedResourceModifiedMessage);
+			for (IPersistedResourceModifiedMessage persistedResourceModifiedMessage :
+					persistedResourceModifiedMsgsPage) {
+				boolean wasProcessed = myResourceModifiedConsumer.submitPersisedResourceModifiedMessage(
+						persistedResourceModifiedMessage);
 
 				if (!wasProcessed) {
 					// we're not fetching anymore no matter what