Skip to content

Add support for mqtt5 #151

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
Open

Add support for mqtt5 #151

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
5ecabd0
Add support for mqtt5
catcherwong Mar 23, 2024
e1f1f94
clean useless code
catcherwong Mar 24, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 19 additions & 1 deletion mqtt_jmeter/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>net.xmeter</groupId>
<artifactId>mqtt-jmeter</artifactId>
<version>2.0.2</version>
<version>2.0.3</version>

<properties>
<jmeter-version>5.5</jmeter-version>
Expand Down Expand Up @@ -37,6 +37,24 @@
<version>1.3.0</version>
</dependency>

<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
<version>1.2.5</version>
</dependency>

<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.mqttv5.client</artifactId>
<version>1.2.5</version>
</dependency>

<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcpkix-jdk15on</artifactId>
<version>1.70</version>
</dependency>

<dependency>
<groupId>org.apache.jmeter</groupId>
<artifactId>jorphan</artifactId>
Expand Down
22 changes: 20 additions & 2 deletions mqtt_jmeter/src/main/java/net/xmeter/Constants.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ public interface Constants {

public static final String PROTOCOL = "mqtt.protocol";
public static final String WS_PATH = "mqtt.ws_path";
public static final String WS_HEADER = "mqtt.ws_header";
public static final String DUAL_AUTH = "mqtt.dual_ssl_authentication";
public static final String CERT_FILE_PATH1 = "mqtt.keystore_file_path";
public static final String CERT_FILE_PATH2 = "mqtt.clientcert_file_path";
Expand All @@ -17,6 +18,8 @@ public interface Constants {

public static final String USER_NAME_AUTH = "mqtt.user_name";
public static final String PASSWORD_AUTH = "mqtt.password";
public static final String AUTH_METHOD = "mqtt.auth_method";
public static final String AUTH_DATA = "mqtt.auth_data";

public static final String CONN_CLIENT_ID_PREFIX = "mqtt.client_id_prefix";
public static final String CONN_CLIENT_ID_SUFFIX = "mqtt.client_id_suffix";
Expand All @@ -26,6 +29,10 @@ public interface Constants {
public static final String CONN_RECONN_ATTEMPT_MAX = "mqtt.reconn_attempt_max";

public static final String CONN_CLEAN_SESSION = "mqtt.conn_clean_session";

public static final String CONN_USER_PROPERTY = "mqtt.conn_user_property";
public static final String CONN_CLEAN_START = "mqtt.conn_clean_start";
public static final String CONN_SESSION_EXPIRY_INTERVAL = "mqtt.conn_session_expiry_interval";

public static final String MESSAGE_TYPE = "mqtt.message_type";
public static final String MESSAGE_FIX_LENGTH = "mqtt.message_type_fixed_length";
Expand All @@ -35,6 +42,15 @@ public interface Constants {
public static final String QOS_LEVEL = "mqtt.qos_level";
public static final String ADD_TIMESTAMP = "mqtt.add_timestamp";
public static final String RETAINED_MESSAGE = "mqtt.retained_message";

public static final String CORRELATION_DATA = "mqtt.correlation_data";
public static final String MESSAGE_EXPIRY_INTERVAL = "mqtt.message_expiry_interval";
public static final String USER_PROPERTIES = "mqtt.user_properties";
public static final String CONTENT_TYPE = "mqtt.content_type";
public static final String RESPONSE_TOPIC = "mqtt.response_topic";
public static final String PAYLOAD_FORMAT = "mqtt.payload_format_indicator";
public static final String TOPIC_ALIAS = "mqtt.topic_alias";
public static final String SUBSCRIPTION_IDENTIFIER = "mqtt.subscription_identifier";

public static final String SAMPLE_CONDITION_VALUE = "mqtt.sample_condition_value";
public static final String SAMPLE_CONDITION = "mqtt.sample_condition";
Expand All @@ -53,7 +69,7 @@ public interface Constants {

public static final String MQTT_VERSION_3_1_1 = "3.1.1";
public static final String MQTT_VERSION_3_1 = "3.1";

public static final String MQTT_VERSION_5_0 = "5.0";
public static final String SAMPLE_ON_CONDITION_OPTION1 = "specified elapsed time (ms)";
public static final String SAMPLE_ON_CONDITION_OPTION2 = "number of received messages";

Expand All @@ -69,9 +85,10 @@ public interface Constants {
public static final String WSS_PROTOCOL = "WSS";
public static final String DEFAULT_PROTOCOL = TCP_PROTOCOL;
public static final String FUSESOURCE_MQTT_CLIENT_NAME = "fusesource";
public static final String PAHO_MQTT_CLIENT_NAME = "paho";
public static final String HIVEMQ_MQTT_CLIENT_NAME = "hivemq";
// public static final String DEFAULT_MQTT_CLIENT_NAME = FUSESOURCE_MQTT_CLIENT_NAME;
public static final String DEFAULT_MQTT_CLIENT_NAME = HIVEMQ_MQTT_CLIENT_NAME;
public static final String DEFAULT_MQTT_CLIENT_NAME = PAHO_MQTT_CLIENT_NAME;

public static final String JMETER_VARIABLE_PREFIX = "${";

Expand All @@ -82,6 +99,7 @@ public interface Constants {
public static final String DEFAULT_CONN_KEEP_ALIVE = "300";
public static final String DEFAULT_CONN_ATTEMPT_MAX = "0";
public static final String DEFAULT_CONN_RECONN_ATTEMPT_MAX = "0";
public static final String DEFAULT_CONN_USER_PROPERTY = "{}";

public static final String DEFAULT_SAMPLE_VALUE_COUNT = "1";
public static final String DEFAULT_SAMPLE_VALUE_ELAPSED_TIME_MILLI_SEC = "1000";
Expand Down
Loading