|
Rename Method public registerReadHandler(handler Function<ReadRequest,CompletableFuture<ReadResponse>>) : void renamed to public registerConsumeHandler(handler Function<ConsumeRequest,CompletableFuture<ConsumeResponse>>) : void in class io.atomix.protocols.log.protocol.LogServerProtocol |
From |
To |
|
Rename Method public unregisterReadHandler() : void renamed to public unregisterConsumeHandler() : void in class io.atomix.protocols.log.protocol.LogServerProtocol |
From |
To |
|
Rename Method public offset() : long renamed to public index() : long in class io.atomix.primitive.log.Record |
From |
To |
|
Rename Method private execute(request AppendRequest) : CompletableFuture<AppendResponse> renamed to private reset(request ResetRequest) : void in class io.atomix.protocols.log.impl.DistributedLogServerContext |
From |
To |
|
Rename Method private sendAndReceive(subject String, request T, memberId MemberId) : CompletableFuture<U> renamed to private send(subject String, request T, memberId MemberId) : CompletableFuture<U> in class io.atomix.protocols.log.partition.impl.LogServerCommunicator |
From |
To |
|
Rename Method public read(request ReadRequest) : CompletableFuture<ReadResponse> renamed to public consume(request ConsumeRequest) : CompletableFuture<ConsumeResponse> in class io.atomix.protocols.log.roles.LogServerRole |
From |
To |
|
Rename Method public registerReadHandler(handler Function<ReadRequest,CompletableFuture<ReadResponse>>) : void renamed to public registerConsumeHandler(handler Function<ConsumeRequest,CompletableFuture<ConsumeResponse>>) : void in class io.atomix.protocols.log.partition.impl.LogServerCommunicator |
From |
To |
|
Rename Method public read(index long, batchSize int) : CompletableFuture<List<Record>> renamed to public consume(index long, consumer Consumer<Record>) : CompletableFuture<Void> in class io.atomix.primitive.log.LogConsumer |
From |
To |
|
Rename Method private sendAndReceive(subject String, request T, memberId MemberId) : CompletableFuture<U> renamed to private send(subject String, request T, memberId MemberId) : CompletableFuture<U> in class io.atomix.protocols.log.partition.impl.LogClientCommunicator |
From |
To |
|
Rename Method public unregisterReadHandler() : void renamed to public unregisterConsumeHandler() : void in class io.atomix.protocols.log.partition.impl.LogServerCommunicator |
From |
To |
|
Rename Method public read(index long, batchSize int) : CompletableFuture<List<Record>> renamed to public consume(index long, consumer Consumer<Record>) : CompletableFuture<Void> in class io.atomix.protocols.log.impl.DistributedLogSession.DistributedLogConsumer |
From |
To |
|
Change Parameter Type batchSize : int to consumer : Consumer<Record> in method public consume(index long, consumer Consumer<Record>) : CompletableFuture<Void> in class io.atomix.primitive.log.LogConsumer |
From |
To |
|
Change Parameter Type handler : Function<ReadRequest,CompletableFuture<ReadResponse>> to handler : Function<ConsumeRequest,CompletableFuture<ConsumeResponse>> in method public registerConsumeHandler(handler Function<ConsumeRequest,CompletableFuture<ConsumeResponse>>) : void in class io.atomix.protocols.log.partition.impl.LogServerCommunicator |
From |
To |
|
Change Parameter Type request : AppendRequest to request : ResetRequest in method private reset(request ResetRequest) : void in class io.atomix.protocols.log.impl.DistributedLogServerContext |
From |
To |
|
Change Parameter Type handler : Function<ReadRequest,CompletableFuture<ReadResponse>> to handler : Function<ConsumeRequest,CompletableFuture<ConsumeResponse>> in method public registerConsumeHandler(handler Function<ConsumeRequest,CompletableFuture<ConsumeResponse>>) : void in class io.atomix.protocols.log.protocol.LogServerProtocol |
From |
To |
|
Change Parameter Type request : ReadRequest to request : ConsumeRequest in method public consume(request ConsumeRequest) : CompletableFuture<ConsumeResponse> in class io.atomix.protocols.log.roles.LogServerRole |
From |
To |
|
Change Parameter Type batchSize : int to consumer : Consumer<Record> in method public consume(index long, consumer Consumer<Record>) : CompletableFuture<Void> in class io.atomix.protocols.log.impl.DistributedLogSession.DistributedLogConsumer |
From |
To |