From 256e4f8c9f4aaff44c118933a60bf3a639b704fc Mon Sep 17 00:00:00 2001 From: Nick Palmer Date: Mon, 31 Oct 2022 12:30:35 +0000 Subject: [PATCH] BaseEventHandler -> EventHandlerBase --- src/main/java/com/lmax/disruptor/BatchEventProcessor.java | 4 ++-- src/main/java/com/lmax/disruptor/EventHandler.java | 2 +- .../{BaseEventHandler.java => EventHandlerBase.java} | 2 +- src/main/java/com/lmax/disruptor/RewindableEventHandler.java | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) rename src/main/java/com/lmax/disruptor/{BaseEventHandler.java => EventHandlerBase.java} (98%) diff --git a/src/main/java/com/lmax/disruptor/BatchEventProcessor.java b/src/main/java/com/lmax/disruptor/BatchEventProcessor.java index fb66a0399..46dffcace 100644 --- a/src/main/java/com/lmax/disruptor/BatchEventProcessor.java +++ b/src/main/java/com/lmax/disruptor/BatchEventProcessor.java @@ -38,7 +38,7 @@ public final class BatchEventProcessor private ExceptionHandler exceptionHandler; private final DataProvider dataProvider; private final SequenceBarrier sequenceBarrier; - private final BaseEventHandler eventHandler; + private final EventHandlerBase eventHandler; private final int batchLimitOffset; private final Sequence sequence = new Sequence(Sequencer.INITIAL_CURSOR_VALUE); private BatchRewindStrategy batchRewindStrategy = new SimpleBatchRewindStrategy(); @@ -48,7 +48,7 @@ public final class BatchEventProcessor private BatchEventProcessor( final DataProvider dataProvider, final SequenceBarrier sequenceBarrier, - final BaseEventHandler eventHandler, + final EventHandlerBase eventHandler, final int maxBatchSize, final boolean rewindable ) diff --git a/src/main/java/com/lmax/disruptor/EventHandler.java b/src/main/java/com/lmax/disruptor/EventHandler.java index b30192c11..c23306df7 100644 --- a/src/main/java/com/lmax/disruptor/EventHandler.java +++ b/src/main/java/com/lmax/disruptor/EventHandler.java @@ -21,7 +21,7 @@ * @param event implementation storing the data for sharing during exchange or parallel coordination of an event. * @see BatchEventProcessor#setExceptionHandler(ExceptionHandler) if you want to handle exceptions propagated out of the handler. */ -public interface EventHandler extends BaseEventHandler +public interface EventHandler extends EventHandlerBase { /** * Called when a publisher has published an event to the {@link RingBuffer}. The {@link BatchEventProcessor} will diff --git a/src/main/java/com/lmax/disruptor/BaseEventHandler.java b/src/main/java/com/lmax/disruptor/EventHandlerBase.java similarity index 98% rename from src/main/java/com/lmax/disruptor/BaseEventHandler.java rename to src/main/java/com/lmax/disruptor/EventHandlerBase.java index 64eb54fe1..2ed0db9f6 100644 --- a/src/main/java/com/lmax/disruptor/BaseEventHandler.java +++ b/src/main/java/com/lmax/disruptor/EventHandlerBase.java @@ -15,7 +15,7 @@ */ package com.lmax.disruptor; -interface BaseEventHandler +interface EventHandlerBase { /** * Called when a publisher has published an event to the {@link RingBuffer}. The {@link BatchEventProcessor} will diff --git a/src/main/java/com/lmax/disruptor/RewindableEventHandler.java b/src/main/java/com/lmax/disruptor/RewindableEventHandler.java index b485dc256..058828b30 100644 --- a/src/main/java/com/lmax/disruptor/RewindableEventHandler.java +++ b/src/main/java/com/lmax/disruptor/RewindableEventHandler.java @@ -22,7 +22,7 @@ * @param event implementation storing the data for sharing during exchange or parallel coordination of an event. * @see BatchEventProcessor#setExceptionHandler(ExceptionHandler) if you want to handle exceptions propagated out of the handler. */ -public interface RewindableEventHandler extends BaseEventHandler +public interface RewindableEventHandler extends EventHandlerBase { /** * Called when a publisher has published an event to the {@link RingBuffer}. The {@link BatchEventProcessor} will