Skip to content

Commit

Permalink
Remove unused symbols
Browse files Browse the repository at this point in the history
  • Loading branch information
caicancai committed Jun 29, 2024
1 parent 2907ab6 commit ece20f9
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -985,12 +985,12 @@ protected int adjustTimeout(final int timeoutMs) {

this.configManager = new ConfigurationManager();

this.applyDisruptor = DisruptorBuilder.<LogEntryAndClosure> newInstance() //
.setRingBufferSize(this.raftOptions.getDisruptorBufferSize()) //
.setEventFactory(new LogEntryAndClosureFactory()) //
this.applyDisruptor = DisruptorBuilder.<LogEntryAndClosure> newInstance()
.setRingBufferSize(this.raftOptions.getDisruptorBufferSize())
.setEventFactory(new LogEntryAndClosureFactory())
.setThreadFactory(new NamedThreadFactory("JRaft-NodeImpl-Disruptor-", true)) //
.setProducerType(ProducerType.MULTI) //
.setWaitStrategy(new BlockingWaitStrategy()) //
.setProducerType(ProducerType.MULTI)
.setWaitStrategy(new BlockingWaitStrategy())
.build();
this.applyDisruptor.handleEventsWith(new LogEntryAndClosureHandler());
this.applyDisruptor.setDefaultExceptionHandler(new LogExceptionHandler<Object>(getClass().getSimpleName()));
Expand Down

0 comments on commit ece20f9

Please sign in to comment.