Created
September 9, 2017 20:16
-
-
Save Sammers21/9a6ca8bf745133b7bdfb4634c44b692a to your computer and use it in GitHub Desktop.
vertx-mqtt tests
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
sammers-osx:vertx-mqtt sammers$ mvn clean install | |
[INFO] Scanning for projects... | |
[WARNING] | |
[WARNING] Some problems were encountered while building the effective model for io.vertx:vertx-mqtt:jar:3.5.0-SNAPSHOT | |
[WARNING] 'build.plugins.plugin.version' for org.apache.maven.plugins:maven-failsafe-plugin is missing. @ line 220, column 15 | |
[WARNING] | |
[WARNING] It is highly recommended to fix these problems because they threaten the stability of your build. | |
[WARNING] | |
[WARNING] For this reason, future Maven versions might no longer support building such malformed projects. | |
[WARNING] | |
[INFO] | |
[INFO] ------------------------------------------------------------------------ | |
[INFO] Building Vert.x MQTT 3.5.0-SNAPSHOT | |
[INFO] ------------------------------------------------------------------------ | |
[INFO] | |
[INFO] --- maven-clean-plugin:3.0.0:clean (default-clean) @ vertx-mqtt --- | |
[INFO] Deleting /Users/sammers/vertx-mqtt/target | |
[INFO] Deleting /Users/sammers/vertx-mqtt/src/main/generated (includes = [], excludes = []) | |
[INFO] Deleting /Users/sammers/vertx-mqtt/src/main/asciidoc (includes = [], excludes = [images/**]) | |
[INFO] | |
[INFO] --- maven-enforcer-plugin:1.0:enforce (enforce-maven) @ vertx-mqtt --- | |
[INFO] | |
[INFO] --- maven-processor-plugin:3.2.0:process (generate-sources) @ vertx-mqtt --- | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded cheatsheet code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded cheatsheet code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded Ruby code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded JavaScript code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded Groovy code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded Groovy code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded Groovy code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded Groovy code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded Kotlin code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded RxJava code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded RxJava2 code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Loaded data_object_converters code generator | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttAuth: io.vertx.reactivex.mqtt.MqttAuth | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClient: io.vertx.rxjava.mqtt.MqttClient | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttServer: io.vertx.reactivex.mqtt.MqttServer | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttServer: io.vertx.rxjava.mqtt.MqttServer | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubscribeMessage: io.vertx.rxjava.mqtt.messages.MqttSubscribeMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttMessage: io.vertx.reactivex.mqtt.messages.MqttMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttTopicSubscription: io.vertx.rxjava.mqtt.MqttTopicSubscription | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubAckMessage: io.vertx.reactivex.mqtt.messages.MqttSubAckMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttMessage: io.vertx.rxjava.mqtt.messages.MqttMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttAuth: io.vertx.rxjava.mqtt.MqttAuth | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttEndpoint: io.vertx.reactivex.mqtt.MqttEndpoint | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttUnsubscribeMessage: io.vertx.rxjava.mqtt.messages.MqttUnsubscribeMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttPublishMessage: io.vertx.rxjava.mqtt.messages.MqttPublishMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttWill: io.vertx.rxjava.mqtt.MqttWill | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttServer: io.vertx.groovy.mqtt.MqttServer_GroovyStaticExtension | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttConnAckMessage: io.vertx.rxjava.mqtt.messages.MqttConnAckMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttWill: io.vertx.reactivex.mqtt.MqttWill | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClient: io.vertx.groovy.mqtt.MqttClient_GroovyStaticExtension | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttPublishMessage: io.vertx.reactivex.mqtt.messages.MqttPublishMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttConnAckMessage: io.vertx.reactivex.mqtt.messages.MqttConnAckMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttUnsubscribeMessage: io.vertx.reactivex.mqtt.messages.MqttUnsubscribeMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt: io.vertx.groovy.mqtt.VertxPropertiesModuleFactory | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubAckMessage: io.vertx.rxjava.mqtt.messages.MqttSubAckMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClient: io.vertx.reactivex.mqtt.MqttClient | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubscribeMessage: io.vertx.reactivex.mqtt.messages.MqttSubscribeMessage | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttTopicSubscription: io.vertx.reactivex.mqtt.MqttTopicSubscription | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttEndpoint: io.vertx.rxjava.mqtt.MqttEndpoint | |
Cannot generate VertxMqttClientExamples#example8 : It is not be possible to render an async result directly | |
Cannot generate VertxMqttClientExamples#example8 : It is not be possible to render an async result directly | |
Cannot generate VertxMqttClientExamples#example8 : It is not be possible to render an async result directly | |
Cannot generate VertxMqttClientExamples#example8 : It is not be possible to render an async result directly | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubscribeMessage: vertx-mqtt-server-js/mqtt_subscribe_message.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttAuth: META-INF/services/org.codehaus.groovy.runtime.ExtensionModule | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttServer: vertx-mqtt-server-js/mqtt_server.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttAuth: vertx-mqtt-server/mqtt_auth.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttMessage: vertx-mqtt-server/mqtt_message.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttPublishMessage: vertx-mqtt-server/mqtt_publish_message.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttConnAckMessage: vertx-mqtt-server/mqtt_conn_ack_message.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubscribeMessage: vertx-mqtt-server/mqtt_subscribe_message.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttEndpoint: vertx-mqtt-server/mqtt_endpoint.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClient: vertx-mqtt-server-js/mqtt_client.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttConnAckMessage: vertx-mqtt-server-js/mqtt_conn_ack_message.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttServer: vertx-mqtt-server/mqtt_server.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttWill: vertx-mqtt-server-js/mqtt_will.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClient: vertx-mqtt-server/mqtt_client.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubAckMessage: vertx-mqtt-server/mqtt_sub_ack_message.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttPublishMessage: vertx-mqtt-server-js/mqtt_publish_message.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttWill: vertx-mqtt-server/mqtt_will.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttAuth: vertx-mqtt-server-js/mqtt_auth.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttEndpoint: vertx-mqtt-server-js/mqtt_endpoint.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttTopicSubscription: vertx-mqtt-server-js/mqtt_topic_subscription.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttTopicSubscription: vertx-mqtt-server/mqtt_topic_subscription.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttUnsubscribeMessage: vertx-mqtt-server/mqtt_unsubscribe_message.rb | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttSubAckMessage: vertx-mqtt-server-js/mqtt_sub_ack_message.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttMessage: vertx-mqtt-server-js/mqtt_message.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.messages.MqttUnsubscribeMessage: vertx-mqtt-server-js/mqtt_unsubscribe_message.js | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttServerOptions: kotlin/io/vertx/kotlin/mqtt/MqttServerOptions.kt | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClientOptions: asciidoc/dataobjects.adoc | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClientOptions: kotlin/io/vertx/kotlin/mqtt/MqttClientOptions.kt | |
INFO: io.vertx.codegen.CodeGenProcessor - Generated model io.vertx.mqtt.MqttClientOptions: generated/io/vertx/mqtt/MqttClientOptionsConverter.java | |
[WARNING] diagnostic: warning: The following options were not recognized by any processor: '[maven.artifactId, maven.version, codegen.output.data_object_converters, codegen.rxjava.deprecated, maven.groupId]' | |
[INFO] | |
[INFO] --- build-helper-maven-plugin:1.12:add-source (add-source) @ vertx-mqtt --- | |
[INFO] Source directory: /Users/sammers/vertx-mqtt/src/main/generated added. | |
[INFO] | |
[INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ vertx-mqtt --- | |
[INFO] Changes detected - recompiling the module! | |
[INFO] Compiling 61 source files to /Users/sammers/vertx-mqtt/target/classes | |
[INFO] | |
[INFO] --- kotlin-maven-plugin:1.1.0:compile (default) @ vertx-mqtt --- | |
[INFO] Kotlin Compiler version 1.1.0 | |
[INFO] Compiling Kotlin sources from [/Users/sammers/vertx-mqtt/src/main/kotlin] | |
[INFO] Module name is vertx-mqtt | |
[WARNING] /Users/sammers/vertx-mqtt/src/main/kotlin/io/vertx/kotlin/mqtt/MqttServerOptions.kt: (99, 10) 'setClientAuthRequired(Boolean): NetServerOptions!' is deprecated. Deprecated in Java | |
[INFO] | |
[INFO] --- maven-resources-plugin:2.7:resources (default-resources) @ vertx-mqtt --- | |
[INFO] Using 'UTF-8' encoding to copy filtered resources. | |
[INFO] skip non existing resourceDirectory /Users/sammers/vertx-mqtt/src/main/resources | |
[INFO] | |
[INFO] --- bnd-maven-plugin:3.2.0:bnd-process (default-bnd-process) @ vertx-mqtt --- | |
[WARNING] /Users/sammers/vertx-mqtt/pom.xml [0:0]: Unused Import-Package instructions: [io.vertx.groovy.*, io.vertx.lang.groovy.*] | |
[WARNING] /Users/sammers/vertx-mqtt/pom.xml [0:0]: Invalid package name: 'vertx-mqtt-server' | |
[WARNING] /Users/sammers/vertx-mqtt/pom.xml [0:0]: Invalid package name: 'vertx-mqtt-server-js' | |
[INFO] | |
[INFO] --- maven-resources-plugin:2.7:testResources (default-testResources) @ vertx-mqtt --- | |
[INFO] Using 'UTF-8' encoding to copy filtered resources. | |
[INFO] Copying 3 resources | |
[INFO] | |
[INFO] --- maven-compiler-plugin:3.1:testCompile (default-testCompile) @ vertx-mqtt --- | |
[INFO] Changes detected - recompiling the module! | |
[INFO] Compiling 26 source files to /Users/sammers/vertx-mqtt/target/test-classes | |
[INFO] | |
[INFO] --- maven-surefire-plugin:2.18.1:test (default-test) @ vertx-mqtt --- | |
[INFO] Surefire report directory: /Users/sammers/vertx-mqtt/target/surefire-reports | |
------------------------------------------------------- | |
T E S T S | |
------------------------------------------------------- | |
Running io.vertx.mqtt.test.server.MqttServerBadClientTest | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.core.impl.ContextImpl | |
SEVERE: Unhandled exception | |
java.lang.IllegalStateException: Received an MQTT packet from a not connected client (CONNECT not sent yet) | |
at io.vertx.mqtt.impl.MqttServerConnection.checkConnected(MqttServerConnection.java:402) | |
at io.vertx.mqtt.impl.MqttServerConnection.handlePublish(MqttServerConnection.java:318) | |
at io.vertx.mqtt.impl.MqttServerConnection.handleMessage(MqttServerConnection.java:130) | |
at io.vertx.mqtt.impl.MqttServerImpl.lambda$null$3(MqttServerImpl.java:89) | |
at io.vertx.core.net.impl.NetSocketImpl.handleMessageReceived(NetSocketImpl.java:358) | |
at io.vertx.core.net.impl.NetServerImpl$2.handleMessage(NetServerImpl.java:423) | |
at io.vertx.core.net.impl.NetServerImpl$2.handleMessage(NetServerImpl.java:420) | |
at io.vertx.core.net.impl.VertxHandler.lambda$channelRead$1(VertxHandler.java:150) | |
at io.vertx.core.impl.ContextImpl.lambda$wrapTask$2(ContextImpl.java:342) | |
at io.vertx.core.impl.ContextImpl.executeFromIO(ContextImpl.java:200) | |
at io.vertx.core.net.impl.VertxHandler.channelRead(VertxHandler.java:148) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) | |
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:341) | |
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) | |
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:341) | |
at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:287) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) | |
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:341) | |
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293) | |
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) | |
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:341) | |
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) | |
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) | |
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:642) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:565) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:479) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:441) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) | |
at java.lang.Thread.run(Thread.java:748) | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.core.net.impl.ConnectionBase | |
SEVERE: io.netty.handler.codec.DecoderException: java.lang.IllegalArgumentException: unknown message type: 15 | |
сен 09, 2017 11:13:59 PM io.vertx.core.net.impl.ConnectionBase | |
SEVERE: io.netty.handler.codec.DecoderException: java.lang.IllegalArgumentException: unknown message type: 0 | |
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.974 sec - in io.vertx.mqtt.test.server.MqttServerBadClientTest | |
Running io.vertx.mqtt.test.server.MqttServerClientIdentifierTest | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.core.net.impl.ConnectionBase | |
SEVERE: io.netty.handler.codec.mqtt.MqttIdentifierRejectedException: invalid clientIdentifier: invalid-id-with-24-chars | |
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.115 sec - in io.vertx.mqtt.test.server.MqttServerClientIdentifierTest | |
Running io.vertx.mqtt.test.server.MqttServerClientPublishTest | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerClientPublishTest | |
INFO: Just received message on [/my_topic] payload [Hello Vert.x MQTT Server] with QoS [AT_MOST_ONCE] | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerClientPublishTest | |
INFO: Just received message on [/my_topic] payload [Hello Vert.x MQTT Server] with QoS [AT_LEAST_ONCE] | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerClientPublishTest | |
INFO: Just received message on [/my_topic] payload [Hello Vert.x MQTT Server] with QoS [EXACTLY_ONCE] | |
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.085 sec - in io.vertx.mqtt.test.server.MqttServerClientPublishTest | |
Running io.vertx.mqtt.test.server.MqttServerConnectionTest | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_ACCEPTED | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: client id = 12345 | |
сен 09, 2017 11:13:59 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: No CONNECT sent in 5 secs. Closing connection. | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_SERVER_UNAVAILABLE | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_SERVER_UNAVAILABLE | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_NOT_AUTHORIZED | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_NOT_AUTHORIZED | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_ACCEPTED | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: client id = 12345 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_ACCEPTED | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: client id = c31e439d-09c4-46d2-a584-52f657a073ae | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_BAD_USER_NAME_OR_PASSWORD | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_BAD_USER_NAME_OR_PASSWORD | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_UNACCEPTABLE_PROTOCOL_VERSION | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_IDENTIFIER_REJECTED | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerConnectionTest | |
INFO: return code = CONNECTION_REFUSED_IDENTIFIER_REJECTED | |
Tests run: 10, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 5.312 sec - in io.vertx.mqtt.test.server.MqttServerConnectionTest | |
Running io.vertx.mqtt.test.server.MqttServerDisconnectTest | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
Клиент подключен (32100) | |
at org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:31) | |
at org.eclipse.paho.client.mqttv3.internal.ClientComms.close(ClientComms.java:189) | |
at org.eclipse.paho.client.mqttv3.MqttAsyncClient.close(MqttAsyncClient.java:1172) | |
at org.eclipse.paho.client.mqttv3.MqttClient.close(MqttClient.java:439) | |
at io.vertx.mqtt.test.server.MqttServerDisconnectTest.bruteDisconnect(MqttServerDisconnectTest.java:74) | |
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) | |
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) | |
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) | |
at java.lang.reflect.Method.invoke(Method.java:498) | |
at io.vertx.ext.unit.junit.VertxUnitRunner.invokeTestMethod(VertxUnitRunner.java:95) | |
at io.vertx.ext.unit.junit.VertxUnitRunner.lambda$invokeExplosively$0(VertxUnitRunner.java:114) | |
at io.vertx.ext.unit.impl.TestContextImpl$Step.run(TestContextImpl.java:122) | |
at io.vertx.ext.unit.impl.TestContextImpl$Step.access$600(TestContextImpl.java:30) | |
at io.vertx.ext.unit.impl.TestContextImpl.run(TestContextImpl.java:221) | |
at io.vertx.ext.unit.junit.VertxUnitRunner.invokeExplosively(VertxUnitRunner.java:130) | |
at io.vertx.ext.unit.junit.VertxUnitRunner.access$000(VertxUnitRunner.java:39) | |
at io.vertx.ext.unit.junit.VertxUnitRunner$1.evaluate(VertxUnitRunner.java:84) | |
at io.vertx.ext.unit.junit.VertxUnitRunner$2.evaluate(VertxUnitRunner.java:196) | |
at io.vertx.ext.unit.junit.VertxUnitRunner$3.evaluate(VertxUnitRunner.java:211) | |
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325) | |
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78) | |
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57) | |
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290) | |
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71) | |
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288) | |
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58) | |
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268) | |
at org.junit.runners.ParentRunner.run(ParentRunner.java:363) | |
at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:283) | |
at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:173) | |
at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:153) | |
at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:128) | |
at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203) | |
at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155) | |
at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103) | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerDisconnectTest | |
INFO: MQTT remote client connection closed | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerDisconnectTest | |
INFO: MQTT remote client disconnected | |
сен 09, 2017 11:14:04 PM io.vertx.mqtt.test.server.MqttServerDisconnectTest | |
INFO: MQTT remote client connection closed | |
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.073 sec - in io.vertx.mqtt.test.server.MqttServerDisconnectTest | |
Running io.vertx.mqtt.test.server.MqttServerEndpointStatusTest | |
сен 09, 2017 11:14:05 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:05 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:05 PM io.vertx.mqtt.test.server.MqttServerEndpointStatusTest | |
INFO: MQTT remote client disconnected | |
сен 09, 2017 11:14:06 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 3.087 sec - in io.vertx.mqtt.test.server.MqttServerEndpointStatusTest | |
Running io.vertx.mqtt.test.server.MqttServerMaxMessageSizeTest | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.MqttServerMaxMessageSizeTest | |
SEVERE: Exception raised | |
io.netty.handler.codec.DecoderException: too large message: 62 bytes | |
at io.netty.handler.codec.mqtt.MqttDecoder.decode(MqttDecoder.java:83) | |
at io.netty.handler.codec.ReplayingDecoder.callDecode(ReplayingDecoder.java:367) | |
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:248) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) | |
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:341) | |
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1334) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:363) | |
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:349) | |
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:926) | |
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:129) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:642) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:565) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:479) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:441) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) | |
at java.lang.Thread.run(Thread.java:748) | |
Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.021 sec - in io.vertx.mqtt.test.server.MqttServerMaxMessageSizeTest | |
Running io.vertx.mqtt.test.server.MqttServerNetworkIssueTest | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.Proxy | |
INFO: Error starting proxy server | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.Proxy | |
INFO: Error connecting proxy client | |
io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:1883 | |
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) | |
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) | |
at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:347) | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:340) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:630) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:565) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:479) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:441) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) | |
at java.lang.Thread.run(Thread.java:748) | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.Proxy | |
INFO: Proxy server stopped | |
Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.073 sec <<< FAILURE! - in io.vertx.mqtt.test.server.MqttServerNetworkIssueTest | |
keepAliveTimeout(io.vertx.mqtt.test.server.MqttServerNetworkIssueTest) Time elapsed: 0.073 sec <<< ERROR! | |
io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: localhost/127.0.0.1:1883 | |
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) | |
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) | |
at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:347) | |
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:340) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:630) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:565) | |
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:479) | |
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:441) | |
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858) | |
at java.lang.Thread.run(Thread.java:748) | |
Running io.vertx.mqtt.test.server.MqttServerPublishTest | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.MqttServerPublishTest | |
INFO: Just received message [Hello Vert.x MQTT Server] on topic [/my_topic] with QoS [0] | |
сен 09, 2017 11:14:08 PM io.vertx.mqtt.test.server.MqttServerBaseTest | |
INFO: MQTT server listening on port 1883 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment