diff --git a/example/main.go b/example/main.go index 53f6ad9..62a4365 100644 --- a/example/main.go +++ b/example/main.go @@ -20,7 +20,11 @@ var ring = [BufferSize]int64{} func main() { runtime.GOMAXPROCS(2) - controller := disruptor.Configure(BufferSize, SampleConsumer{}).Build() + controller := disruptor. + Configure(BufferSize). + WithConsumerGroup(SampleConsumer{}). + Build() + controller.Start() started := time.Now() diff --git a/wireup.go b/wireup.go index 57f3f81..7a38a57 100644 --- a/wireup.go +++ b/wireup.go @@ -10,14 +10,12 @@ type ( } ) -func Configure(capacity int64, consumers ...Consumer) Wireup { - this := Wireup{ +func Configure(capacity int64) Wireup { + return Wireup{ capacity: capacity, groups: [][]Consumer{}, cursors: []*Cursor{NewCursor()}, } - - return this.WithConsumerGroup(consumers...) } func (this Wireup) WithConsumerGroup(consumers ...Consumer) Wireup {