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

apply patch
2014-02-17 13:33:07 -05:00 · 2014-02-17 13:33:07 -05:00 · b97fa15d53
parent b679787917
commit b97fa15d53
1 changed files with 2 additions and 1 deletions
--- a/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
+++ b/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
@ -381,7 +381,8 @@ public class MQTTProtocolConverter {
        return topic.qos();
    }

-    void onUnSubscribe(UNSUBSCRIBE command) {
+    void onUnSubscribe(UNSUBSCRIBE command) throws MQTTProtocolException {
+        checkConnected();
        UTF8Buffer[] topics = command.topics();
        if (topics != null) {
            for (UTF8Buffer topic : topics) {