spotless
This commit is contained in:
parent
07e90d9f4e
commit
eb768b83ad
|
@ -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;
|
||||
|
|
|
@ -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
|
||||
|
|
Loading…
Reference in New Issue