Add test case for LocalFileOffsetStore closes apache/incubator-rocketmq#59
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/0adad6f0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/0adad6f0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/0adad6f0 Branch: refs/heads/release-4.1.0-incubating Commit: 0adad6f0025483647e760c1145f7736462c0ec79 Parents: e5d01b4 Author: djKooks <inylov...@gmail.com> Authored: Sat May 27 11:06:37 2017 +0800 Committer: dongeforever <zhendongli...@yeah.net> Committed: Sat May 27 11:06:37 2017 +0800 ---------------------------------------------------------------------- .../consumer/store/LocalFileOffsetStoreTest.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/0adad6f0/client/src/test/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStoreTest.java ---------------------------------------------------------------------- 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 22e212b..a705b30 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<MessageQueue>(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<MessageQueue, Long> cloneOffsetTable = offsetStore.cloneOffsetTable(topic); + + assertThat(cloneOffsetTable.size()).isEqualTo(1); + assertThat(cloneOffsetTable.get(messageQueue)).isEqualTo(1024); + } } \ No newline at end of file