[
https://issues.apache.org/jira/browse/ARTEMIS-607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15360765#comment-15360765
]
ASF GitHub Bot commented on ARTEMIS-607:
----------------------------------------
Github user johnament commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/617#discussion_r69403171
--- Diff:
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTTest.java
---
@@ -380,7 +384,8 @@ public void testMQTTPathPatterns() throws Exception {
Message msg = connection.receive(5, TimeUnit.SECONDS);
do {
assertNotNull("RETAINED null " + wildcard, msg);
- assertTrue("RETAINED prefix " + wildcard, new
String(msg.getPayload()).startsWith(RETAINED));
+ String msgPayload = new String(msg.getPayload());
--- End diff --
One worrisome thing. I think there's some interdependence in these tests.
I originally added my interceptor checks in a new test method. When I did
that, this test started failing. It was receiving the messages created
previously. I suspect the server isn't getting cleaned up 100% correctly, or
maybe not at all.
> Implement support for Interceptors with the MQTT protocol
> ---------------------------------------------------------
>
> Key: ARTEMIS-607
> URL: https://issues.apache.org/jira/browse/ARTEMIS-607
> Project: ActiveMQ Artemis
> Issue Type: New Feature
> Components: Broker
> Affects Versions: 1.3.0
> Reporter: Jiri Danek
>
> Intercepting MQTT messages is not yet supported, only core protocol messages
> can be intercepted. I would like to request a feature for MQTT interceptor
> support.
> This feature was recently requested on the users@ mailing list
> http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-td4713408.html
> I encountered this issue when trying to answer
> http://stackoverflow.com/questions/38101899/intercepting-mqtt-messages-in-artemis
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
