I have an embedded activeMQ broker listening to two ports. Here's my broker-config file :
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"; xmlns:amq="http://activemq.apache.org/schema/core"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd";> <broker xmlns="http://activemq.apache.org/schema/core"; useJmx="true" useShutdownHook="false" brokerName="mimo.broker1"> <managementContext> <managementContext createConnector="false"/> </managementContext> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage limit="64 mb"/> </memoryUsage> <storeUsage> <storeUsage limit="100 gb"/> </storeUsage> <tempUsage> <tempUsage limit="50 gb"/> </tempUsage> </systemUsage> </systemUsage> <persistenceAdapter> <kahaDB directory="activemq-data/kahadb"/> </persistenceAdapter> <transportConnectors> <transportConnector name="mimo.broker1" uri="tcp://0.0.0.0:61616" /> <transportConnector name="mqtt+ws" uri="ws://0.0.0.0:1884"/> </transportConnectors> </broker> </beans> When I launch my jboss server I see that the broker is launched and listening to ports: 11:00:33,792 INFO [org.apache.activemq.transport.TransportServerThreadSupport] (Starting ActiveMQ Broker) Listening for connections at: tcp://DESKTOP-4D80FU1:61616 11:00:33,793 INFO [org.apache.activemq.broker.TransportConnector] (Starting ActiveMQ Broker) Connector mimo.broker1 started 11:00:33,849 INFO [org.eclipse.jetty.server.Server] (Starting ActiveMQ Broker) jetty-7.6.9.v20130131 11:00:33,876 INFO [org.eclipse.jetty.server.handler.ContextHandler] (Starting ActiveMQ Broker) started o.e.j.s.ServletContextHandler{/,null} 11:00:33,905 INFO [org.eclipse.jetty.server.AbstractConnector] (Starting ActiveMQ Broker) Started SelectChannelConnector@0.0.0.0:1884 11:00:33,906 INFO [org.apache.activemq.transport.ws.WSTransportServer] (Starting ActiveMQ Broker) Listening for connections at ws://DESKTOP-4D80FU1:1884 11:00:33,907 INFO [org.apache.activemq.broker.TransportConnector] (Starting ActiveMQ Broker) Connector mqtt+ws started 11:00:33,908 INFO [org.apache.activemq.broker.BrokerService] (Starting ActiveMQ Broker) Apache ActiveMQ 5.9.0 (mimo.broker1, ID:DESKTOP-4D80FU1-57645-1494493233653-0:1) started 11:00:33,909 INFO [org.apache.activemq.broker.BrokerService] (Starting ActiveMQ Broker) For help or more information please see: http://activemq.apache.org I tried a mqtt client using java paho mqttv3, this is how I tried to connect to my broker: String broker = "ws://127.0.0.1:1883"; String clientId = "JavaSample"; MemoryPersistence persistence = new MemoryPersistence(); try { MqttAsyncClient sampleClient = new MqttAsyncClient(broker, clientId, persistence); MqttConnectOptions connOpts = new MqttConnectOptions(); connOpts.setCleanSession(true); connOpts.setAutomaticReconnect(true); IMqttToken token = sampleClient.connect(connOpts); }catch(MqttException e){ e.printStackTrace(); } My problem is that the connection is never getting established with the broker. I am getting this warn when I try to connect to broker "[WARN [org.apache.activemq.broker.TransportConnection.Transport] (qtp906254668-147) Transport Connection to: MQTTSocket_248153872 failed: java.io.IOException: Invalid CONNECT encoding". I tried to connect to mosquitto remote broker "tcp://test.mosquitto.org:1883" and it works. Could someone help me with this? Is this an activeMQ configuration problem? -- View this message in context: http://activemq.2283324.n4.nabble.com/WARN-org-apache-activemq-broker-TransportConnection-Transport-qtp906254668-147-Transport-Connection-g-tp4725962.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
