File tree Expand file tree Collapse file tree
tieredstore/src/test/java/org/apache/rocketmq/tieredstore Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -238,22 +238,9 @@ public void testGetMinOffsetInQueue() {
238238 Mockito .when (defaultStore .getMinOffsetInQueue (anyString (), anyInt ())).thenReturn (100L );
239239 Assert .assertEquals (100L , currentStore .getMinOffsetInQueue (mq .getTopic (), mq .getQueueId ()));
240240
241+ Mockito .when (defaultStore .getMinOffsetInQueue (anyString (), anyInt ())).thenReturn (-1L );
241242 Assert .assertEquals (flatFile .getConsumeQueueMinOffset (),
242243 currentStore .getMinOffsetInQueue (mq .getTopic (), mq .getQueueId ()));
243-
244- FlatFileStore mockFlatFileStore = Mockito .mock (FlatFileStore .class );
245- FlatMessageFile mockFlatFile = Mockito .mock (FlatMessageFile .class );
246- Mockito .when (mockFlatFileStore .getFlatFile (any (MessageQueue .class ))).thenReturn (mockFlatFile );
247- Mockito .when (mockFlatFile .getConsumeQueueMinOffset ()).thenReturn (10L );
248- Mockito .when (defaultStore .getMinOffsetInQueue (anyString (), anyInt ())).thenReturn (-1L );
249- try {
250- Field field = currentStore .getClass ().getDeclaredField ("flatFileStore" );
251- field .setAccessible (true );
252- field .set (currentStore , mockFlatFileStore );
253- } catch (NoSuchFieldException | IllegalAccessException e ) {
254- Assert .fail (e .getClass ().getCanonicalName () + ": " + e .getMessage ());
255- }
256- Assert .assertEquals (10L , currentStore .getMinOffsetInQueue (mq .getTopic (), mq .getQueueId ()));
257244 }
258245
259246 @ Test
You can’t perform that action at this time.
0 commit comments