diff --git a/libbeat/publisher/pipeline/module.go b/libbeat/publisher/pipeline/module.go
index 4fb5282f582..e5e2a18eb63 100644
--- a/libbeat/publisher/pipeline/module.go
+++ b/libbeat/publisher/pipeline/module.go
@@ -157,6 +157,10 @@ func createQueueBuilder(config common.ConfigNamespace) (func(queue.Eventer) (que
 		queueConfig = common.NewConfig()
 	}
 
+	stateRegistry := monitoring.GetNamespace("state").GetRegistry()
+	queueRegistry := stateRegistry.NewRegistry("queue")
+	monitoring.NewString(queueRegistry, "name").Set(queueType)
+
 	return func(eventer queue.Eventer) (queue.Queue, error) {
 		return queueFactory(eventer, queueConfig)
 	}, nil