Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

https://issues.apache.org/jira/browse/AMQ-5880 

Adds a test for the issue that is ignored for now while we wait for a
fixed MQTT client release.
This commit is contained in:
Timothy Bish 2016-03-01 16:18:16 -05:00
parent e375af3810
commit 8ef44452a2
1 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
View File

@ -64,6 +64,7 @@ import org.fusesource.mqtt.client.Topic;
import org.fusesource.mqtt.client.Tracer;
import org.fusesource.mqtt.codec.MQTTFrame;
import org.fusesource.mqtt.codec.PUBLISH;
import org.junit.Ignore;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -1337,6 +1338,37 @@ public class MQTTTest extends MQTTTestSupport {
jmsConn.close();
}
@Ignore("Needs fix in MQTT client for string length decode.")
@Test(timeout = 30 * 10000)
public void testSubscribeWithLargeTopicFilter() throws Exception {
byte[] payload = new byte[1024 * 32];
for (int i = 0; i < payload.length; i++) {
payload[i] = '2';
}
StringBuilder topicBuilder = new StringBuilder("/topic/");
for (int i = 0; i < 32800; ++i) {
topicBuilder.append("a");
}
MQTT mqtt = createMQTTConnection();
mqtt.setClientId("MQTT-Client");
mqtt.setCleanSession(false);
final BlockingConnection connection = mqtt.blockingConnection();
connection.connect();
Topic[] topic = { new Topic(topicBuilder.toString(), QoS.EXACTLY_ONCE) };
connection.subscribe(topic);
connection.publish(topic[0].name().toString(), payload, QoS.AT_LEAST_ONCE, false);
Message message = connection.receive();
assertNotNull(message);
message.ack();
}
@Test(timeout = 30 * 10000)
public void testSubscribeMultipleTopics() throws Exception {