diff --git a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java
index ced752d8..5f10596c 100644
--- a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java
+++ b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttAsyncClient.java
@@ -1161,7 +1161,7 @@ private IMqttToken subscribeBase(MqttSubscription[] subscriptions, Object userCo
 		token.setActionCallback(callback);
 		token.setUserContext(userContext);
 		// TODO - Somehow refactor this....
-		// token.internalTok.setTopics(topicFilters);
+		token.internalTok.setTopics(topicFilters);
 		// TODO - Build up MQTT Subscriptions properly here
 
 		MqttSubscribe register = new MqttSubscribe(subscriptions, subscriptionProperties);