Skip to content

Commit

Permalink
revert NewBroker change from elastic/beats#8091 since it has not been…
Browse files Browse the repository at this point in the history
… backport yet
  • Loading branch information
graphaelli committed Sep 11, 2018
1 parent 13dced6 commit 5b330a8
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion beater/beater_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -310,7 +310,7 @@ func DummyPipeline(clients ...outputs.Client) *pipeline.Pipeline {
beat.Info{Name: "test-apm-server"},
nil,
func(e queue.Eventer) (queue.Queue, error) {
return memqueue.NewBroker(nil, memqueue.Settings{
return memqueue.NewBroker(memqueue.Settings{
Eventer: e,
Events: 20,
}), nil
Expand Down

0 comments on commit 5b330a8

Please sign in to comment.