Skip to content

Add support for mqtt5#151

Open
catcherwong wants to merge 2 commits intoemqx:masterfrom
catcherwong:support-mqtt5
Open

Add support for mqtt5#151
catcherwong wants to merge 2 commits intoemqx:masterfrom
catcherwong:support-mqtt5

Conversation

@catcherwong
Copy link
Copy Markdown

This PR did the following things:

  1. Introduce Paho MQTT client both v3 and v5, and set the default client to it.
  2. Add UserProperty, CleanStart and SessionExpiryInterval in Conn Pannel.
  3. Add WS Header in Protocol Panel
  4. Add UserProperties, MessageExpiryInterval, TopicAlias, PayloadFormat,ContentType ,ResponseTopic,CorrelationData and SubscriptionIdentifier in Publish Option Pannel
  5. Replace p12 cert with CA Cert, Client Cert and Client Private Key when using dual ssl.

Signed-off-by: catcherwong <catcher_hwq@outlook.com>
Signed-off-by: catcherwong <catcher_hwq@outlook.com>
@Host32
Copy link
Copy Markdown

Host32 commented Jan 21, 2025

up!

@Host32
Copy link
Copy Markdown

Host32 commented Jan 21, 2025

The build of this branch for anyone who needs it while the PR is not merged:

mqttvt-xmeter-jar-with-dependencies.zip

@andrei-shyliayeu
Copy link
Copy Markdown

andrei-shyliayeu commented Feb 19, 2025

MessageExpiryInterval could be undefined, so this parameter on GUI should accept and allow to save undefined value. Some brokers (e.g. ActiveMQ Artemis) interpret a value "0" as Expired Immediately.

@wu159753
Copy link
Copy Markdown

wu159753 commented May 26, 2025

I use dual ssl, but jmter run error. My key is EC encrypted type.
net.xmeter.samplers.ConnectSampler sample
SEVERE: Failed to establish Connection null
java.lang.ClassCastException: class org.bouncycastle.asn1.pkcs.PrivateKeyInfo cannot be cast to class org.bouncycastle.openssl.PEMKeyPair (org.bouncycastle.asn1.pkcs.PrivateKeyInfo and org.bouncycastle.openssl.PEMKeyPair are in unnamed module of loader org.apache.jmeter.DynamicClassLoader @4517d9a3)
at net.xmeter.samplers.mqtt.paho.PahoUtil.getSocketFactory(PahoUtil.java:115)
at net.xmeter.samplers.mqtt.paho.PahoMQTT5Client.connect(PahoMQTT5Client.java:69)
at net.xmeter.samplers.ConnectSampler.sample(ConnectSampler.java:96)
at org.apache.jmeter.threads.JMeterThread.doSampling(JMeterThread.java:651)
at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:570)
at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:501)
at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:268)
at java.base/java.lang.Thread.run(Thread.java:833)
image

@marcelomrwin
Copy link
Copy Markdown

I tried using your plugin but consumers don't receive any messages, unfortunately.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants