diff --git a/libbeat/publisher/queue/queue_reg.go b/libbeat/publisher/queue/queue_reg.go
index 38bf36a29c9..0bc0ca3e4ea 100644
--- a/libbeat/publisher/queue/queue_reg.go
+++ b/libbeat/publisher/queue/queue_reg.go
@@ -18,9 +18,6 @@
 package queue
 
 import (
-	"fmt"
-
-	"github.com/elastic/beats/libbeat/common"
 	"github.com/elastic/beats/libbeat/feature"
 )
 
@@ -51,20 +48,6 @@ func FindFactory(name string) Factory {
 	return factory
 }
 
-// Load instantiates a new queue.
-func Load(eventer Eventer, config common.ConfigNamespace) (Queue, error) {
-	t, cfg := config.Name(), config.Config()
-	if t == "" {
-		t = "mem"
-	}
-
-	factory := FindFactory(t)
-	if factory == nil {
-		return nil, fmt.Errorf("queue type %v undefined", t)
-	}
-	return factory(eventer, cfg)
-}
-
 // Feature creates a new type of queue.
 func Feature(name string, factory Factory, stability feature.Stability) *feature.Feature {
 	return feature.New(Namespace, name, factory, stability)