Skip to content

Commit

Permalink
BaseEventHandler -> EventHandlerBase
Browse files Browse the repository at this point in the history
  • Loading branch information
Palmr committed Oct 31, 2022
1 parent 922d02f commit 256e4f8
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions src/main/java/com/lmax/disruptor/BatchEventProcessor.java
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ public final class BatchEventProcessor<T>
private ExceptionHandler<? super T> exceptionHandler;
private final DataProvider<T> dataProvider;
private final SequenceBarrier sequenceBarrier;
private final BaseEventHandler<? super T> eventHandler;
private final EventHandlerBase<? super T> eventHandler;
private final int batchLimitOffset;
private final Sequence sequence = new Sequence(Sequencer.INITIAL_CURSOR_VALUE);
private BatchRewindStrategy batchRewindStrategy = new SimpleBatchRewindStrategy();
Expand All @@ -48,7 +48,7 @@ public final class BatchEventProcessor<T>
private BatchEventProcessor(
final DataProvider<T> dataProvider,
final SequenceBarrier sequenceBarrier,
final BaseEventHandler<? super T> eventHandler,
final EventHandlerBase<? super T> eventHandler,
final int maxBatchSize,
final boolean rewindable
)
Expand Down
2 changes: 1 addition & 1 deletion src/main/java/com/lmax/disruptor/EventHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
* @param <T> 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<T> extends BaseEventHandler<T>
public interface EventHandler<T> extends EventHandlerBase<T>
{
/**
* Called when a publisher has published an event to the {@link RingBuffer}. The {@link BatchEventProcessor} will
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
*/
package com.lmax.disruptor;

interface BaseEventHandler<T>
interface EventHandlerBase<T>
{
/**
* Called when a publisher has published an event to the {@link RingBuffer}. The {@link BatchEventProcessor} will
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
* @param <T> 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<T> extends BaseEventHandler<T>
public interface RewindableEventHandler<T> extends EventHandlerBase<T>
{
/**
* Called when a publisher has published an event to the {@link RingBuffer}. The {@link BatchEventProcessor} will
Expand Down

0 comments on commit 256e4f8

Please sign in to comment.