>From the logs, it looks like the URI used for your connection is using tcp:// as the transport protocol, whereas an MQTT connection use mqtt://. And is the port you're connecting to running the MQTT protocol, or is it an OpenWire port?
Tim On Mon, Apr 20, 2020, 10:02 AM JJ <gerardo.tro...@euronet.aero> wrote: > Simple MQTT connection produce continously errors, and after few seconds > client disconnection. > > activemq.xml is the default one. > > Any help/hint? > > java.net.SocketException: Connection reset > at java.base/java.net > .SocketInputStream.read(SocketInputStream.java:186)[:] > at java.base/java.net > .SocketInputStream.read(SocketInputStream.java:140)[:] > at > > org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)[activemq-client-5.15.12.jar:5.15.12] > at > > org.apache.activemq.transport.tcp.TcpTransport$2.fill(TcpTransport.java:634)[activemq-client-5.15.12.jar:5.15.12] > at > > org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:59)[activemq-client-5.15.12.jar:5.15.12] > at > > org.apache.activemq.transport.tcp.TcpTransport$2.read(TcpTransport.java:619)[activemq-client-5.15.12.jar:5.15.12] > at java.base/java.io > .DataInputStream.readByte(DataInputStream.java:270)[:] > at > > org.apache.activemq.transport.mqtt.MQTTWireFormat.unmarshal(MQTTWireFormat.java:86)[activemq-mqtt-5.15.12.jar:5.15.12] > at > > org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)[activemq-client-5.15.12.jar:5.15.12] > at > > org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)[activemq-client-5.15.12.jar:5.15.12] > at > > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.12.jar:5.15.12] > at java.base/java.lang.Thread.run(Thread.java:834)[:] > 2020-04-20 16:06:07,128 | DEBUG | Unregistering MBean > > org.apache.activemq:type=Broker,brokerName=AMBRACIA,connector=clientConnectors,connectorName=mqtt,connectionViewType=remoteAddress,connectionName=tcp_//xxx.xxx.xxx.xxx_47203 > | org.apache.activemq.broker.jmx.ManagementContext | ActiveMQ Transport: > tcp:///xxx.xxx.xxx.xxx:47203@1883 > 2020-04-20 16:06:07,128 | DEBUG | Stopping connection: > tcp://xxx.xxx.xxx.xxx:47203 | > org.apache.activemq.broker.TransportConnection > | ActiveMQ BrokerService[AMBRACIA] Task-2 > 2020-04-20 16:06:07,129 | DEBUG | Stopping transport > tcp:///xxx.xxx.xxx.xxx:47203@1883 | > org.apache.activemq.transport.tcp.TcpTransport | ActiveMQ > BrokerService[AMBRACIA] Task-2 > 2020-04-20 16:06:07,129 | DEBUG | Initialized TaskRunnerFactory[ActiveMQ > Task] using ExecutorService: > java.util.concurrent.ThreadPoolExecutor@113c1ae6[Running, pool size = 0, > active threads = 0, queued tasks = 0, completed tasks = 0] | > org.apache.activemq.thread.TaskRunnerFactory | ActiveMQ > BrokerService[AMBRACIA] Task-2 > 2020-04-20 16:06:07,130 | DEBUG | Closed socket > Socket[addr=/xxx.xxx.xxx.xxx,port=47203,localport=1883] | > org.apache.activemq.transport.tcp.TcpTransport | ActiveMQ Task-1 > 2020-04-20 16:06:07,131 | DEBUG | Forcing shutdown of ExecutorService: > java.util.concurrent.ThreadPoolExecutor@113c1ae6[Running, pool size = 1, > active threads = 0, queued tasks = 0, completed tasks = 1] | > org.apache.activemq.util.ThreadPoolUtils | ActiveMQ BrokerService[AMBRACIA] > Task-2 > 2020-04-20 16:06:07,131 | DEBUG | Stopped transport: > tcp://xxx.xxx.xxx.xxx:47203 | > org.apache.activemq.broker.TransportConnection > | ActiveMQ BrokerService[AMBRACIA] Task-2 > 2020-04-20 16:06:07,132 | DEBUG | Connection Stopped: > tcp://xxx.xxx.xxx.xxx:47203 | > org.apache.activemq.broker.TransportConnection > | ActiveMQ BrokerService[AMBRACIA] Task-2 > 2020-04-20 16:06:08,140 | DEBUG | Transport Connection to: > tcp://xxx.xxx.xxx.xxx:47213 failed: java.net.SocketException: Connection > reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ > Transport: tcp:///xxx.xxx.xxx.xxx:47213@1883 > > > > -- > Sent from: > http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html >
