You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2014/02/17 19:33:47 UTC
git commit: https://issues.apache.org/jira/browse/AMQ-5059
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 <ta...@gmai.com>
Authored: Mon Feb 17 13:33:07 2014 -0500
Committer: Timothy Bish <ta...@gmai.com>
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) {