You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2020/03/25 16:12:08 UTC
[activemq-artemis] branch master updated: NO-JIRA fix failing MQTT
test
This is an automated email from the ASF dual-hosted git repository.
jbertram pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/master by this push:
new b9fa8b9 NO-JIRA fix failing MQTT test
b9fa8b9 is described below
commit b9fa8b96ec06c9acdf2c4eff9c85cb1f3ee1a7a8
Author: Justin Bertram <jb...@apache.org>
AuthorDate: Wed Mar 25 11:10:09 2020 -0500
NO-JIRA fix failing MQTT test
I've seen o.a.a.a.c.p.m.MQTTRetainMessageManagerTest fail a handful of
times recently in PR builds. This change fixes that failure.
---
.../apache/activemq/artemis/core/protocol/mqtt/MqttClientService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MqttClientService.java b/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MqttClientService.java
index cd80056..e3b852d 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MqttClientService.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MqttClientService.java
@@ -66,7 +66,7 @@ public class MqttClientService implements MqttCallback {
final MqttConnectOptions options = new MqttConnectOptions();
options.setAutomaticReconnect(true);
options.setCleanSession(false);
- options.setMaxInflight(10);
+ options.setMaxInflight(1000);
options.setServerURIs(new String[] {serverURI});
options.setMqttVersion(MQTT_VERSION_3_1_1);