diff --git a/server/src/main/java/com/hedera/block/server/persistence/PersistenceInjectionModule.java b/server/src/main/java/com/hedera/block/server/persistence/PersistenceInjectionModule.java index a8abc2ccb..a447ddb9f 100644 --- a/server/src/main/java/com/hedera/block/server/persistence/PersistenceInjectionModule.java +++ b/server/src/main/java/com/hedera/block/server/persistence/PersistenceInjectionModule.java @@ -26,8 +26,8 @@ import com.hedera.block.server.persistence.storage.write.BlockAsLocalFileWriter; import com.hedera.block.server.persistence.storage.write.BlockWriter; import com.hedera.block.server.persistence.storage.write.NoOpBlockWriter; -import com.hedera.block.server.persistence.storage.write.factory.AsyncBlockWriterFactory; import com.hedera.block.server.persistence.storage.write.factory.AsyncBlockAsLocalFileWriterFactory; +import com.hedera.block.server.persistence.storage.write.factory.AsyncBlockWriterFactory; import com.hedera.hapi.block.BlockItemUnparsed; import com.hedera.hapi.block.BlockUnparsed; import com.hedera.hapi.block.SubscribeStreamResponseUnparsed; diff --git a/server/src/main/java/com/hedera/block/server/persistence/StreamPersistenceHandlerImpl.java b/server/src/main/java/com/hedera/block/server/persistence/StreamPersistenceHandlerImpl.java index 4b688352c..3c0cf9fca 100644 --- a/server/src/main/java/com/hedera/block/server/persistence/StreamPersistenceHandlerImpl.java +++ b/server/src/main/java/com/hedera/block/server/persistence/StreamPersistenceHandlerImpl.java @@ -213,6 +213,7 @@ private void handleBlockItems(final List blockItems) final BlockPersistenceResult blockPersistenceResult = completionResult.get(); if (blockPersistenceResult.status().equals(BlockPersistenceStatus.SUCCESS)) { final long blockNumber = blockPersistenceResult.blockNumber(); + // @todo(545) migrate the ackHandler to work with persistence results ackHandler.blockPersisted(blockNumber); metricsService.get(BlocksPersisted).increment(); LOGGER.log(INFO, "Block [%s] persisted successfully.".formatted(blockNumber)); diff --git a/server/src/main/java/com/hedera/block/server/persistence/storage/write/factory/AsyncBlockAsLocalFileWriterFactory.java b/server/src/main/java/com/hedera/block/server/persistence/storage/write/factory/AsyncBlockAsLocalFileWriterFactory.java index 78d114fe8..4d6be4d53 100644 --- a/server/src/main/java/com/hedera/block/server/persistence/storage/write/factory/AsyncBlockAsLocalFileWriterFactory.java +++ b/server/src/main/java/com/hedera/block/server/persistence/storage/write/factory/AsyncBlockAsLocalFileWriterFactory.java @@ -3,8 +3,8 @@ import com.hedera.block.server.persistence.storage.compression.Compression; import com.hedera.block.server.persistence.storage.path.BlockPathResolver; -import com.hedera.block.server.persistence.storage.write.AsyncBlockWriter; import com.hedera.block.server.persistence.storage.write.AsyncBlockAsLocalFileWriter; +import com.hedera.block.server.persistence.storage.write.AsyncBlockWriter; import edu.umd.cs.findbugs.annotations.NonNull; import jakarta.inject.Inject; import java.util.Objects;