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);