anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SubscriptionsStoreTest: classname used for static access

Browse Source
This commit is contained in:
Andreas Mager
2017-01-30 15:50:42 +01:00
parent 504ac3055e
commit f460d6a230
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/test/java/io/moquette/spi/impl/subscriptions/SubscriptionsStoreTest.java
+12 -12
View File
@@ -53,55 +53,55 @@ public class SubscriptionsStoreTest {
@Test
public void testParseTopic() throws ParseException {
List<Token> tokens = store.parseTopic("finance/stock/ibm");
List<Token> tokens = SubscriptionsStore.parseTopic("finance/stock/ibm");
assertEqualsSeq(asArray("finance", "stock", "ibm"), tokens);
tokens = store.parseTopic("/finance/stock/ibm");
tokens = SubscriptionsStore.parseTopic("/finance/stock/ibm");
assertEqualsSeq(asArray(Token.EMPTY, "finance", "stock", "ibm"), tokens);
tokens = store.parseTopic("/");
tokens = SubscriptionsStore.parseTopic("/");
assertEqualsSeq(asArray(Token.EMPTY, Token.EMPTY), tokens);
}
@Test
public void testParseTopicMultiValid() throws ParseException {
List<Token> tokens = store.parseTopic("finance/stock/#");
List<Token> tokens = SubscriptionsStore.parseTopic("finance/stock/#");
assertEqualsSeq(asArray("finance", "stock", Token.MULTI), tokens);
tokens = store.parseTopic("#");
tokens = SubscriptionsStore.parseTopic("#");
assertEqualsSeq(asArray(Token.MULTI), tokens);
}
@Test(expected = ParseException.class)
public void testParseTopicMultiInTheMiddleNotValid() throws ParseException {
store.parseTopic("finance/#/closingprice");
SubscriptionsStore.parseTopic("finance/#/closingprice");
}
@Test(expected = ParseException.class)
public void testParseTopicMultiNotAfterSeparatorNotValid() throws ParseException {
store.parseTopic("finance#");
SubscriptionsStore.parseTopic("finance#");
}
@Test(expected = ParseException.class)
public void testParseTopicMultiNotAlone() throws ParseException {
store.parseTopic("/finance/#closingprice");
SubscriptionsStore.parseTopic("/finance/#closingprice");
}
@Test
public void testParseTopicSingleValid() throws ParseException {
List<Token> tokens = store.parseTopic("finance/stock/+");
List<Token> tokens = SubscriptionsStore.parseTopic("finance/stock/+");
assertEqualsSeq(asArray("finance", "stock", Token.SINGLE), tokens);
tokens = store.parseTopic("+");
tokens = SubscriptionsStore.parseTopic("+");
assertEqualsSeq(asArray(Token.SINGLE), tokens);
tokens = store.parseTopic("finance/+/ibm");
tokens = SubscriptionsStore.parseTopic("finance/+/ibm");
assertEqualsSeq(asArray("finance", Token.SINGLE, "ibm"), tokens);
}
@Test(expected = ParseException.class)
public void testParseTopicSingleNotAferSeparatorNotValid() throws ParseException {
store.parseTopic("finance+");
SubscriptionsStore.parseTopic("finance+");
}
@Test