Skip to content

Commit

Permalink
Remove unneeded queue code (#7538)
Browse files Browse the repository at this point in the history
This code was not used.
  • Loading branch information
ruflin authored and Steffen Siering committed Jul 10, 2018
1 parent 9d865a7 commit c0492f8
Showing 1 changed file with 0 additions and 17 deletions.
17 changes: 0 additions & 17 deletions libbeat/publisher/queue/queue_reg.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,6 @@
package queue

import (
"fmt"

"github.com/elastic/beats/libbeat/common"
"github.com/elastic/beats/libbeat/feature"
)

Expand Down Expand Up @@ -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)
Expand Down

0 comments on commit c0492f8

Please sign in to comment.