Revised signature.
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 @@
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 @@
}
)
-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 {
