diff --git a/example/example_producer.go b/example/example_producer.go
index 3f00a46..4ddd222 100644
--- a/example/example_producer.go
+++ b/example/example_producer.go
@@ -16,5 +16,3 @@
 		}
 	}
 }
-
-const ItemsToPublish = 4
diff --git a/example/main.go b/example/main.go
index ab1b4be..9299264 100644
--- a/example/main.go
+++ b/example/main.go
@@ -7,7 +7,8 @@
 )
 
 const MaxConsumersPerGroup = 1
-const MaxConsumerGroups = 2
+const MaxConsumerGroups = 1
+const ItemsToPublish = 1
 
 func main() {
 	runtime.GOMAXPROCS(MaxConsumerGroups*MaxConsumersPerGroup + 1)
@@ -35,17 +36,17 @@
 		reader := disruptor.NewReader(upstreamBarrier, writerCursor, readerCursor)
 
 		// constant time regardless of the number of items
-		// go consume0(disruptor.NewSimpleReader(reader, NewExampleConsumerHandler()))
+		go consume0(disruptor.NewSimpleReader(reader, NewExampleConsumerHandler()))
 
 		// wildly sporadic latency for single-item publish, e.g. 2 seconds, 65 ms, etc.
 		// faster for 2-3+ items per publish
-		// go consume1(reader)
+		//go consume1(reader)
 
-		if group == 0 {
-			go consume1(reader)
-		} else if group == 1 {
-			go consume2(reader)
-		}
+		// if group == 0 {
+		// 	go consume1(reader)
+		// } else if group == 1 {
+		// 	go consume2(reader)
+		// }
 	}
 
 	return disruptor.NewBarrier(readerCursors...)