Merge pull request #410 from SteafanMrZhou/master

A PR for issue#405.
LMAX-Exchange · Mar 2, 2022 · a32218d · a32218d
2 parents 160e798 + 35f2b93
commit a32218d
Show file tree

Hide file tree

Showing 10 changed files with 16 additions and 0 deletions.
diff --git a/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventFactory.java b/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventFactory.java
@@ -5,6 +5,7 @@
 // tag::example[]
 public class LongEventFactory implements EventFactory<LongEvent>
 {
+    @Override
     public LongEvent newInstance()
     {
         return new LongEvent();

diff --git a/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventHandler.java b/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventHandler.java
@@ -5,6 +5,7 @@
 // tag::example[]
 public class LongEventHandler implements EventHandler<LongEvent>
 {
+    @Override
     public void onEvent(LongEvent event, long sequence, boolean endOfBatch)
     {
         System.out.println("Event: " + event);

diff --git a/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventProducer.java b/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventProducer.java
@@ -19,6 +19,7 @@ public LongEventProducer(RingBuffer<LongEvent> ringBuffer)
     private static final EventTranslatorOneArg<LongEvent, ByteBuffer> TRANSLATOR =
         new EventTranslatorOneArg<LongEvent, ByteBuffer>()
         {
+            @Override
             public void translateTo(LongEvent event, long sequence, ByteBuffer bb)
             {
                 event.set(bb.getLong(0));

diff --git a/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventProducerWithTranslator.java b/src/examples/java/com/lmax/disruptor/examples/longevent/LongEventProducerWithTranslator.java
@@ -18,6 +18,7 @@ public LongEventProducerWithTranslator(RingBuffer<LongEvent> ringBuffer)
     private static final EventTranslatorOneArg<LongEvent, ByteBuffer> TRANSLATOR =
         new EventTranslatorOneArg<LongEvent, ByteBuffer>()
         {
+            @Override
             public void translateTo(LongEvent event, long sequence, ByteBuffer bb)
             {
                 event.set(bb.getLong(0));

diff --git a/src/examples/java/com/lmax/disruptor/examples/objectevent/ClearingEventHandler.java b/src/examples/java/com/lmax/disruptor/examples/objectevent/ClearingEventHandler.java
@@ -5,6 +5,7 @@
 
 public class ClearingEventHandler<T> implements EventHandler<ObjectEvent<T>>
 {
+    @Override
     public void onEvent(ObjectEvent<T> event, long sequence, boolean endOfBatch)
     {
         event.clear(); // <1>

diff --git a/src/main/java/com/lmax/disruptor/RingBuffer.java b/src/main/java/com/lmax/disruptor/RingBuffer.java
@@ -440,6 +440,7 @@ public long getCursor()
      *
      * @return size of buffer
      */
+    @Override
     public int getBufferSize()
     {
         return bufferSize;
@@ -455,6 +456,7 @@ public int getBufferSize()
      * @return <code>true</code> If the specified <code>requiredCapacity</code> is available
      * <code>false</code> if not.
      */
+    @Override
     public boolean hasAvailableCapacity(final int requiredCapacity)
     {
         return sequencer.hasAvailableCapacity(requiredCapacity);
@@ -898,6 +900,7 @@ public void publish(final long lo, final long hi)
      *
      * @return The number of slots remaining.
      */
+    @Override
     public long remainingCapacity()
     {
         return sequencer.remainingCapacity();

diff --git a/src/test/java/com/lmax/disruptor/RewindBatchEventProcessorTest.java b/src/test/java/com/lmax/disruptor/RewindBatchEventProcessorTest.java
@@ -451,6 +451,7 @@ public void setRewindable(final BatchEventProcessor<LongEvent> processor)
             this.processor = processor;
         }
 
+        @Override
         public void onEvent(final LongEvent event, final long sequence, final boolean endOfBatch) throws Exception
         {
 

diff --git a/src/test/java/com/lmax/disruptor/alternatives/RingBufferArray.java b/src/test/java/com/lmax/disruptor/alternatives/RingBufferArray.java
@@ -459,6 +459,7 @@ public long getCursor()
      *
      * @return size of buffer
      */
+    @Override
     public int getBufferSize()
     {
         return bufferSize;
@@ -474,6 +475,7 @@ public int getBufferSize()
      * @return <code>true</code> If the specified <code>requiredCapacity</code> is available
      * <code>false</code> if not.
      */
+    @Override
     public boolean hasAvailableCapacity(final int requiredCapacity)
     {
         return sequencer.hasAvailableCapacity(requiredCapacity);
@@ -917,6 +919,7 @@ public void publish(final long lo, final long hi)
      *
      * @return The number of slots remaining.
      */
+    @Override
     public long remainingCapacity()
     {
         return sequencer.remainingCapacity();

diff --git a/src/test/java/com/lmax/disruptor/alternatives/RingBufferUnsafe.java b/src/test/java/com/lmax/disruptor/alternatives/RingBufferUnsafe.java
@@ -472,6 +472,7 @@ public long getCursor()
      *
      * @return size of buffer
      */
+    @Override
     public int getBufferSize()
     {
         return bufferSize;
@@ -487,6 +488,7 @@ public int getBufferSize()
      * @return <code>true</code> If the specified <code>requiredCapacity</code> is available
      * <code>false</code> if not.
      */
+    @Override
     public boolean hasAvailableCapacity(final int requiredCapacity)
     {
         return sequencer.hasAvailableCapacity(requiredCapacity);
@@ -930,6 +932,7 @@ public void publish(final long lo, final long hi)
      *
      * @return The number of slots remaining.
      */
+    @Override
     public long remainingCapacity()
     {
         return sequencer.remainingCapacity();

diff --git a/src/test/java/com/lmax/disruptor/dsl/stubs/StubExceptionHandler.java b/src/test/java/com/lmax/disruptor/dsl/stubs/StubExceptionHandler.java
@@ -28,6 +28,7 @@ public StubExceptionHandler(final AtomicReference<Throwable> exceptionHandled)
         this.exceptionHandled = exceptionHandled;
     }
 
+    @Override
     public void handleEventException(final Throwable ex, final long sequence, final Object event)
     {
         exceptionHandled.set(ex);