opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-31 02:20:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ROCKETMQ-53] Remove testSubscriptionData for rocketmq-common

Browse Source
This commit is contained in:
yukon
2017-01-22 23:37:42 +08:00
parent 23d7e824b6
commit a3aff81e46
1 changed files with 0 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/test/java/org/apache/rocketmq/common/filter/FilterAPITest.java
-18
View File
@@ -20,7 +20,6 @@ package org.apache.rocketmq.common.filter;
import java.util.HashSet;
import java.util.Set;
import org.apache.rocketmq.common.protocol.heartbeat.SubscriptionData;
import org.apache.rocketmq.remoting.protocol.RemotingSerializable;
import org.junit.Test;
import static org.assertj.core.api.Assertions.assertThat;
@@ -43,21 +42,4 @@ public class FilterAPITest {
}
assertThat(subscriptionData.getTagsSet()).isEqualTo(tagSet);
}
@Test
public void testSubscriptionData() throws Exception {
SubscriptionData subscriptionData =
FilterAPI.buildSubscriptionData("ConsumerGroup1", "TestTopic", "TAG1 || Tag2 || tag3");
subscriptionData.setFilterClassSource("java hello");
String prettyJson = RemotingSerializable.toJson(subscriptionData, true);
long subVersion = subscriptionData.getSubVersion();
assertThat(prettyJson).isEqualTo("{\n" +
"\t\"classFilterMode\":false,\n" +
"\t\"codeSet\":[2567159,2598904,3552217],\n" +
"\t\"subString\":\"TAG1 || Tag2 || tag3\",\n" +
"\t\"subVersion\":" + subVersion + ",\n" +
"\t\"tagsSet\":[\"TAG1\",\"Tag2\",\"tag3\"],\n" +
"\t\"topic\":\"TestTopic\"\n" +
"}");
}
}