Browse Source

@ResourceLock("port8885") added for MQTT test with server on port 8885

pull/10684/head
Sergey Matvienko 2 years ago
parent
commit
a1c226ae17
  1. 2
      netty-mqtt/src/test/java/org/thingsboard/mqtt/integration/MqttIntegrationTest.java
  2. 2
      netty-mqtt/src/test/java/org/thingsboard/mqtt/integration/server/MqttServer.java

2
netty-mqtt/src/test/java/org/thingsboard/mqtt/integration/MqttIntegrationTest.java

@ -27,6 +27,7 @@ import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.parallel.ResourceLock;
import org.thingsboard.common.util.AbstractListeningExecutor; import org.thingsboard.common.util.AbstractListeningExecutor;
import org.thingsboard.mqtt.MqttClient; import org.thingsboard.mqtt.MqttClient;
import org.thingsboard.mqtt.MqttClientConfig; import org.thingsboard.mqtt.MqttClientConfig;
@ -39,6 +40,7 @@ import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
@ResourceLock("port8885") // test MQTT server port
@Slf4j @Slf4j
public class MqttIntegrationTest { public class MqttIntegrationTest {

2
netty-mqtt/src/test/java/org/thingsboard/mqtt/integration/server/MqttServer.java

@ -46,7 +46,7 @@ public class MqttServer {
private EventLoopGroup workerGroup; private EventLoopGroup workerGroup;
public void init() throws Exception { public void init() throws Exception {
log.info("Starting MQTT server..."); log.info("Starting MQTT server on port {}...", mqttPort);
bossGroup = new NioEventLoopGroup(); bossGroup = new NioEventLoopGroup();
workerGroup = new NioEventLoopGroup(); workerGroup = new NioEventLoopGroup();
ServerBootstrap b = new ServerBootstrap(); ServerBootstrap b = new ServerBootstrap();

Loading…
Cancel
Save