Repository: activemq Updated Branches: refs/heads/trunk b67978791 -> b97fa15d5
https://issues.apache.org/jira/browse/AMQ-5059 apply patch Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/b97fa15d Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/b97fa15d Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/b97fa15d Branch: refs/heads/trunk Commit: b97fa15d53b2240b3d9059a311cfcede7f6ff0ee Parents: b679787 Author: Timothy Bish <[email protected]> Authored: Mon Feb 17 13:33:07 2014 -0500 Committer: Timothy Bish <[email protected]> Committed: Mon Feb 17 13:33:07 2014 -0500 ---------------------------------------------------------------------- .../org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/b97fa15d/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java ---------------------------------------------------------------------- diff --git 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 index e9fc9f7..5b8f8c7 100644 --- 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) {
