|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public sendAsync(message InternalRequest) : CompletableFuture<Void> in class io.atomix.messaging.netty.NettyMessagingManager.LocalClientConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalReply in method private dispatch(message InternalReply) : void in class io.atomix.messaging.netty.NettyMessagingManager.RemoteClientConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public sendAndReceive(message InternalRequest) : CompletableFuture<byte[]> in class io.atomix.messaging.netty.NettyMessagingManager.ClientConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public reply(message InternalRequest, status InternalReply.Status, payload Optional<byte[]>) : void in class io.atomix.messaging.netty.NettyMessagingManager.ServerConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method private dispatch(message InternalRequest) : void in class io.atomix.messaging.netty.NettyMessagingManager.RemoteServerConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public sendAndReceive(message InternalRequest) : CompletableFuture<byte[]> in class io.atomix.messaging.netty.NettyMessagingManager.LocalClientConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public sendAndReceive(message InternalRequest) : CompletableFuture<byte[]> in class io.atomix.messaging.netty.NettyMessagingManager.RemoteClientConnection |
From |
To |
|
Change Parameter Type status : InternalMessage.Status to status : InternalReply.Status in method public reply(message InternalRequest, status InternalReply.Status, payload Optional<byte[]>) : void in class io.atomix.messaging.netty.NettyMessagingManager.LocalServerConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public sendAsync(message InternalRequest) : CompletableFuture<Void> in class io.atomix.messaging.netty.NettyMessagingManager.ClientConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public sendAsync(message InternalRequest) : CompletableFuture<Void> in class io.atomix.messaging.netty.NettyMessagingManager.RemoteClientConnection |
From |
To |
|
Change Parameter Type status : InternalMessage.Status to status : InternalReply.Status in method public reply(message InternalRequest, status InternalReply.Status, payload Optional<byte[]>) : void in class io.atomix.messaging.netty.NettyMessagingManager.ServerConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : InternalRequest in method public reply(message InternalRequest, status InternalReply.Status, payload Optional<byte[]>) : void in class io.atomix.messaging.netty.NettyMessagingManager.LocalServerConnection |
From |
To |
|
Change Variable Type messageId : Long to messageId : long in method public sendAndReceive(ep Endpoint, type String, payload byte[], executor Executor) : CompletableFuture<byte[]> in class io.atomix.messaging.netty.NettyMessagingManager |
From |
To |
|
Change Variable Type messagingManager : NettyMessagingManager to messagingService : MessagingService in method private createClient() : RaftClient in class io.atomix.protocols.raft.RaftPerformanceTest |
From |
To |
|
Change Variable Type handler : BiConsumer<InternalMessage,ServerConnection> to handler : BiConsumer<InternalRequest,ServerConnection> in method public sendAndReceive(message InternalRequest) : CompletableFuture<byte[]> in class io.atomix.messaging.netty.NettyMessagingManager.LocalClientConnection |
From |
To |
|
Change Variable Type message : InternalMessage to message : InternalRequest in method public sendAsync(ep Endpoint, type String, payload byte[]) : CompletableFuture<Void> in class io.atomix.messaging.netty.NettyMessagingManager |
From |
To |
|
Change Variable Type status : InternalMessage.Status to status : InternalReply.Status in method public registerHandler(type String, handler BiFunction<Endpoint,byte[],byte[]>, executor Executor) : void in class io.atomix.messaging.netty.NettyMessagingManager |
From |
To |
|
Change Variable Type handler : BiConsumer<InternalMessage,ServerConnection> to handler : BiConsumer<InternalRequest,ServerConnection> in method public sendAsync(message InternalRequest) : CompletableFuture<Void> in class io.atomix.messaging.netty.NettyMessagingManager.LocalClientConnection |
From |
To |
|
Change Variable Type message : InternalMessage to message : InternalRequest in method public sendAndReceive(ep Endpoint, type String, payload byte[], executor Executor) : CompletableFuture<byte[]> in class io.atomix.messaging.netty.NettyMessagingManager |
From |
To |
|
Change Variable Type handler : BiConsumer<InternalMessage,ServerConnection> to handler : BiConsumer<InternalRequest,ServerConnection> in method private dispatch(message InternalRequest) : void in class io.atomix.messaging.netty.NettyMessagingManager.RemoteServerConnection |
From |
To |
|
Change Variable Type messagingManager : NettyMessagingManager to messagingService : MessagingService in method private createServer(memberId MemberId) : RaftServer in class io.atomix.protocols.raft.RaftPerformanceTest |
From |
To |
|
Push Down Method public type() : String from class io.atomix.messaging.netty.InternalMessage to public subject() : String from class io.atomix.messaging.netty.InternalRequest |
From |
To |
|
Push Down Method public toString() : String from class io.atomix.messaging.netty.InternalMessage to public toString() : String from class io.atomix.messaging.netty.InternalReply |
From |
To |
|
Push Down Method public InternalMessage(preamble int, id long, sender Endpoint, payload byte[], status Status) from class io.atomix.messaging.netty.InternalMessage to public InternalReply(preamble int, id long, status Status) from class io.atomix.messaging.netty.InternalReply |
From |
To |
|
Push Down Method public status() : Status from class io.atomix.messaging.netty.InternalMessage to public status() : Status from class io.atomix.messaging.netty.InternalReply |
From |
To |
|
Push Down Method public sender() : Endpoint from class io.atomix.messaging.netty.InternalMessage to public sender() : Endpoint from class io.atomix.messaging.netty.InternalRequest |
From |
To |
|
Push Down Method public InternalMessage(preamble int, id long, sender Endpoint, type String, payload byte[]) from class io.atomix.messaging.netty.InternalMessage to public InternalReply(preamble int, id long, status Status) from class io.atomix.messaging.netty.InternalReply |
From |
To |