diff --git a/datasources/plugin_node.js b/datasources/plugin_node.js
index d550714..81e1e98 100755
--- a/datasources/plugin_node.js
+++ b/datasources/plugin_node.js
@@ -20,8 +20,6 @@
 
 		function onNewMessageHandler(message) {
 
-			console.debug("Message received %s", message);
-
 			var objdata = JSON.parse(message);
 
 			if (typeof objdata == "object") {
@@ -46,19 +44,18 @@
 
 			// Join the rooms
 			self.socket.on('connect', function() {
-				
 				console.info("Connecting to Node.js at: %s", self.url);
-				
-				// Join the rooms
-				_.each(rooms, function(roomConfig) {
-					var roomName = roomConfig.roomName;
-					var roomEvent = roomConfig.roomEvent;
+			});
+			
+			// Join the rooms
+			_.each(rooms, function(roomConfig) {
+				var roomName = roomConfig.roomName;
+				var roomEvent = roomConfig.roomEvent;
 
-					if (!_.isUndefined(roomName) && !_.isUndefined(roomEvent)) {
-						joinRoom(roomName, roomEvent);
-					}
+				if (!_.isUndefined(roomName) && !_.isUndefined(roomEvent)) {
+					joinRoom(roomName, roomEvent);
+				}
 
-				});
 			});
 
 			self.socket.on('connect_error', function(object) {