fix(store): resolve conflicts after rebasing

1. resolve conflicts after rebasing Signed-off-by: TheR1sing3un <[email protected]>
AutoMQ · Oct 11, 2023 · 24536d1 · 24536d1
1 parent 52c5a3f
commit 24536d1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/store/src/test/java/com/automq/rocketmq/store/LogicQueueTest.java b/store/src/test/java/com/automq/rocketmq/store/LogicQueueTest.java
@@ -85,8 +85,8 @@ public void setUp() throws StoreException {
         streamStore = new MockStreamStore();
         stateMachine = Mockito.spy(new DefaultLogicQueueStateMachine(TOPIC_ID, QUEUE_ID, kvService));
         inflightService = new InflightService();
-        SnapshotService snapshotService = new SnapshotService(streamStore, kvService);
-        OperationLogService operationLogService = new StreamOperationLogService(streamStore, snapshotService, new StoreConfig());
+        snapshotService = new SnapshotService(streamStore, kvService);
+        operationLogService = new StreamOperationLogService(streamStore, snapshotService, new StoreConfig());
         logicQueue = new StreamLogicQueue(new StoreConfig(), TOPIC_ID, QUEUE_ID,
             metadataService, stateMachine, streamStore, operationLogService, inflightService);
         logicQueue.open().join();