diff --git a/server/mqtt.go b/server/mqtt.go
index 733dbcf74..fe1cd0a31 100644
--- a/server/mqtt.go
+++ b/server/mqtt.go
@@ -82,7 +82,7 @@ func (m *MQTT) publishComplex(topic string, retained bool, payload interface{})
 
 	case reflect.Map:
 		// loop map
-		for iter := reflect.ValueOf(m).MapRange(); iter.Next(); {
+		for iter := reflect.ValueOf(payload).MapRange(); iter.Next(); {
 			k := iter.Key().String()
 			m.publishComplex(fmt.Sprintf("%s/%s", topic, k), retained, iter.Value().Interface())
 		}