Good afternoon, I am using the ActiveMQ Performance Module version 6.2.9 to perform a test using MQTT:
https://activemq.apache.org/components/classic/documentation/activemq-classic-performance-module-users-manual Is MQTT supported with this module? I have added the activemq-mqtt dependency to the activemq-perf-maven-plugin/pom.xml and built it successfully: ... <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-mqtt</artifactId> </dependency> … I have tried: factory.brokerURL=mqtt://127.0.0.1:1883 and: factory.brokerURL=tcp://127.0.0.1:1883 I get an error using both. For MQTT I get: … Caused by: java.lang.IllegalArgumentException: Invalid connect parameters: {wireFormat.host=172.31.28.95} at org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:130) at org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:69) at org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:365) ... When I switch to: tcp://127.0.0.1:1883 I get this error: ... Caused by: org.apache.activemq.transport.InactivityIOException: Cannot send, channel has already failed: tcp://172.31.28.95:31367 at org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:332) ... Am I missing something? Any suggestions? Thanks. Regards, William Crowell This e-mail may contain information that is privileged or confidential. If you are not the intended recipient, please delete the e-mail and any attachments and notify us immediately.
