@@ -73,11 +73,11 @@ public abstract class AbstractTcpMasterBuilder extends AbstractMasterBuilder {
this.future.removeListener(getOrCreateConnectionListener());
this.future.addListener(ChannelFutureListener.CLOSE);
future = null;
- }
- try {
- Thread.sleep(5000L);
- } catch (InterruptedException e) {
- e.printStackTrace();
+ try {
+ Thread.sleep(5000L);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
}
log.debug("创建连接");
try {
@@ -21,7 +21,7 @@ public class TestTcpCommandMaster {
ModbusTcpMasterBuilder master = new ModbusTcpMasterBuilder("127.0.0.1", 5002);
master.createByUnBlock();
TcpSynchronousWaitingRoom.waitTime = 5000L;
- Thread.sleep(3000L);
Random random = new Random();
BigDecimal val;
BigDecimal val1;