From 16c8d43a603157ee56fdac872e867043c315e1f8 Mon Sep 17 00:00:00 2001 From: djKooks Date: Sat, 27 May 2017 11:06:37 +0800 Subject: [PATCH] Add test case for LocalFileOffsetStore closes apache/incubator-rocketmq#59 --- .../consumer/store/LocalFileOffsetStoreTest.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java b/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java index 22e212b3..a705b30f 100644 --- a/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java +++ b/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java @@ -19,6 +19,8 @@ package org.apache.rocketmq.client.consumer.store; import java.io.File; import java.util.Collections; import java.util.HashSet; +import java.util.Map; + import org.apache.rocketmq.client.ClientConfig; import org.apache.rocketmq.client.impl.factory.MQClientInstance; import org.apache.rocketmq.common.message.MessageQueue; @@ -72,4 +74,15 @@ public class LocalFileOffsetStoreTest { offsetStore.persistAll(new HashSet(Collections.singletonList(messageQueue))); assertThat(offsetStore.readOffset(messageQueue, ReadOffsetType.READ_FROM_STORE)).isEqualTo(1024); } + + @Test + public void testCloneOffset() throws Exception { + OffsetStore offsetStore = new LocalFileOffsetStore(mQClientFactory, group); + MessageQueue messageQueue = new MessageQueue(topic, brokerName, 3); + offsetStore.updateOffset(messageQueue, 1024, false); + Map cloneOffsetTable = offsetStore.cloneOffsetTable(topic); + + assertThat(cloneOffsetTable.size()).isEqualTo(1); + assertThat(cloneOffsetTable.get(messageQueue)).isEqualTo(1024); + } } \ No newline at end of file -- GitLab