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

broker/BrokerInterceptorTest: code formatter used

Browse Source
This commit is contained in:
Andreas Mager
2017-02-01 17:13:42 +01:00
parent 47c76fafc1
commit 0bf059afcf
1 changed files with 25 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/test/java/io/moquette/spi/impl/BrokerInterceptorTest.java
+25 -21
View File
@@ -13,6 +13,7 @@
* *
* You may elect to redistribute this code under either of these licenses. * You may elect to redistribute this code under either of these licenses.
*/ */
package io.moquette.spi.impl; package io.moquette.spi.impl;
import io.moquette.interception.InterceptHandler; import io.moquette.interception.InterceptHandler;
@@ -23,10 +24,8 @@ import io.netty.handler.codec.mqtt.MqttQoS;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import java.util.Arrays; import java.util.Arrays;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.mockito.Matchers.refEq; import static org.mockito.Matchers.refEq;
import static org.mockito.Mockito.mock; import static org.mockito.Mockito.mock;
@@ -36,19 +35,23 @@ import static org.mockito.Mockito.verify;
* @author Wagner Macedo * @author Wagner Macedo
*/ */
public class BrokerInterceptorTest { public class BrokerInterceptorTest {
// value to check for changes after every notification // value to check for changes after every notification
private static final AtomicInteger n = new AtomicInteger(0); private static final AtomicInteger n = new AtomicInteger(0);
// Interceptor loaded with a custom InterceptHandler special for the tests // Interceptor loaded with a custom InterceptHandler special for the tests
private static final class MockObserver implements InterceptHandler { private static final class MockObserver implements InterceptHandler {
@Override
public String getID() { @Override
return "MockObserver"; public String getID() {
} return "MockObserver";
@Override }
public Class<?>[] getInterceptedMessageTypes() {
return InterceptHandler.ALL_MESSAGE_TYPES; @Override
} public Class<?>[] getInterceptedMessageTypes() {
return InterceptHandler.ALL_MESSAGE_TYPES;
}
@Override @Override
public void onConnect(InterceptConnectMessage msg) { public void onConnect(InterceptConnectMessage msg) {
n.set(40); n.set(40);
@@ -79,13 +82,14 @@ public class BrokerInterceptorTest {
n.set(80); n.set(80);
} }
@Override @Override
public void onMessageAcknowledged( InterceptAcknowledgedMessage msg ) { public void onMessageAcknowledged(InterceptAcknowledgedMessage msg) {
n.set(90); n.set(90);
} }
} }
private static final BrokerInterceptor interceptor = new BrokerInterceptor(Arrays.<InterceptHandler>asList(new MockObserver())); private static final BrokerInterceptor interceptor = new BrokerInterceptor(
Arrays.<InterceptHandler>asList(new MockObserver()));
@BeforeClass @BeforeClass
public static void beforeAllTests() { public static void beforeAllTests() {
@@ -112,17 +116,17 @@ public class BrokerInterceptorTest {
@Test @Test
public void testNotifyClientDisconnected() throws Exception { public void testNotifyClientDisconnected() throws Exception {
interceptor.notifyClientDisconnected("cli1234","cli1234"); interceptor.notifyClientDisconnected("cli1234", "cli1234");
interval(); interval();
assertEquals(50, n.get()); assertEquals(50, n.get());
} }
@Test @Test
public void testNotifyTopicPublished() throws Exception { public void testNotifyTopicPublished() throws Exception {
interceptor.notifyTopicPublished(MessageBuilder.publish() interceptor.notifyTopicPublished(
.qos(MqttQoS.AT_MOST_ONCE) MessageBuilder.publish().qos(MqttQoS.AT_MOST_ONCE).payload("Hello".getBytes()).build(),
.payload("Hello".getBytes()) "cli1234",
.build(), "cli1234", "cli1234"); "cli1234");
interval(); interval();
assertEquals(60, n.get()); assertEquals(60, n.get());
} }
@@ -163,7 +167,7 @@ public class BrokerInterceptorTest {
interval(); interval();
// removeInterceptHandler() performs another interaction // removeInterceptHandler() performs another interaction
// TODO: fix this // TODO: fix this
// verifyNoMoreInteractions(interceptHandlerMock1); // verifyNoMoreInteractions(interceptHandlerMock1);
verify(interceptHandlerMock2).onSubscribe(refEq(new InterceptSubscribeMessage(subscription, "cli1235"))); verify(interceptHandlerMock2).onSubscribe(refEq(new InterceptSubscribeMessage(subscription, "cli1235")));
} }
} }