diff --git a/src/main/java/de/hottis/measurementCollector/MqttReceiver.java b/src/main/java/de/hottis/measurementCollector/MqttReceiver.java
index 463ad28..09bdea0 100644
--- a/src/main/java/de/hottis/measurementCollector/MqttReceiver.java
+++ b/src/main/java/de/hottis/measurementCollector/MqttReceiver.java
@@ -81,10 +81,9 @@ public class MqttReceiver {
 			while (true) {
 				try {
 					client.connect(connOpts);
-					for (String topic : parsers.keySet()) {
-						client.subscribe(topic);
-						logger.info("Re-Subscribed: " + topic);
-					}
+                                        String[] topics = parsers.keySet().toArray(new String[0]);
+					client.subscribe(topics);
+					logger.info("Re-Subscribed: " + topics.toString());
 					logger.error("reconnecting successfully completed");
 					break;
 				} catch (MqttException e) {