From 2b804261532ae10db073cdccbfdf04ace999dc95 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michal=20T=C3=B3th?= Date: Wed, 21 Jun 2017 13:17:54 +0200 Subject: [PATCH] ARTEMIS-1244 Retain flag code todo comment Identified possible bug in MQTT receive of missing retained flag. --- .../integration/mqtt/imported/MQTTInterceptorPropertiesTest.java | 1 + 1 file changed, 1 insertion(+) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTInterceptorPropertiesTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTInterceptorPropertiesTest.java index 375e2f2986..0b6219456e 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTInterceptorPropertiesTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTInterceptorPropertiesTest.java @@ -64,6 +64,7 @@ public class MQTTInterceptorPropertiesTest extends MQTTTestSupport { MqttFixedHeader header = message.fixedHeader(); assertNotNull(header.messageType()); assertEquals(header.qosLevel().value(), AT_MOST_ONCE); + // TODO resolve the following line based on result of ARTEMIS-1244, currently fails (2.1.0) assertEquals(header.isRetain(), expectedProperties.get(RETAINED)); } catch (Throwable t) { collector.addError(t);