diff --git a/agrona/src/main/java/com/aeroncookbook/agrona/ringbuffer/SendAgent2.java b/agrona/src/main/java/com/aeroncookbook/agrona/ringbuffer/SendAgent2.java index 1804f83f..8ed4c833 100644 --- a/agrona/src/main/java/com/aeroncookbook/agrona/ringbuffer/SendAgent2.java +++ b/agrona/src/main/java/com/aeroncookbook/agrona/ringbuffer/SendAgent2.java @@ -36,7 +36,7 @@ public SendAgent2(final ManyToOneRingBuffer ringBuffer, final int sendCount) @Override public int doWork() { - if (currentCountItem > sendCount) + if (currentCountItem < sendCount) { return 0; }