The performance module was built to support the jms/openwire protocol. > On Aug 13, 2026, at 12:05 PM, William Crowell via users > <[email protected]> wrote: > > 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. >
--------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected] For further information, visit: https://activemq.apache.org/contact
