|
Change Parameter Type message : InternalReply to message : ProtocolReply in method private dispatch(message ProtocolReply) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteClientConnection |
From |
To |
|
Change Parameter Type status : InternalReply.Status to status : ProtocolReply.Status in method public reply(message ProtocolRequest, status ProtocolReply.Status, payload Optional<byte[]>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.ServerConnection |
From |
To |
|
Change Parameter Type message : InternalMessage to message : ProtocolMessage in method private encodeMessage(message ProtocolMessage, buffer ByteBuf) : void in class io.atomix.cluster.messaging.impl.MessageEncoderV1 |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public sendAndReceive(message ProtocolRequest, timeout Duration) : CompletableFuture<byte[]> in class io.atomix.cluster.messaging.impl.NettyMessagingService.ClientConnection |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method private dispatch(message ProtocolRequest) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteServerConnection |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public sendAsync(message ProtocolRequest) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.NettyMessagingService.ClientConnection |
From |
To |
|
Change Parameter Type reply : InternalReply to reply : ProtocolReply in method private encodeReply(reply ProtocolReply, out ByteBuf) : void in class io.atomix.cluster.messaging.impl.MessageEncoderV1 |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public reply(message ProtocolRequest, status ProtocolReply.Status, payload Optional<byte[]>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteServerConnection |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public sendAndReceive(message ProtocolRequest, timeout Duration) : CompletableFuture<byte[]> in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteClientConnection |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public sendAndReceive(message ProtocolRequest, timeout Duration) : CompletableFuture<byte[]> in class io.atomix.cluster.messaging.impl.NettyMessagingService.LocalClientConnection |
From |
To |
|
Change Parameter Type status : InternalReply.Status to status : ProtocolReply.Status in method public reply(message ProtocolRequest, status ProtocolReply.Status, payload Optional<byte[]>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.LocalServerConnection |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public reply(message ProtocolRequest, status ProtocolReply.Status, payload Optional<byte[]>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.ServerConnection |
From |
To |
|
Change Parameter Type request : InternalRequest to request : ProtocolRequest in method private encodeRequest(request ProtocolRequest, out ByteBuf) : void in class io.atomix.cluster.messaging.impl.MessageEncoderV1 |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public reply(message ProtocolRequest, status ProtocolReply.Status, payload Optional<byte[]>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.LocalServerConnection |
From |
To |
|
Change Parameter Type status : InternalReply.Status to status : ProtocolReply.Status in method public reply(message ProtocolRequest, status ProtocolReply.Status, payload Optional<byte[]>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteServerConnection |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public sendAsync(message ProtocolRequest) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.NettyMessagingService.LocalClientConnection |
From |
To |
|
Change Parameter Type message : InternalRequest to message : ProtocolRequest in method public sendAsync(message ProtocolRequest) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteClientConnection |
From |
To |
|
Change Variable Type message : InternalReply to message : ProtocolReply in method protected decode(context ChannelHandlerContext, buffer ByteBuf, out List<Object>) : void in class io.atomix.cluster.messaging.impl.MessageDecoderV1 |
From |
To |
|
Change Variable Type message : InternalRequest to message : ProtocolRequest in method public sendAndReceive(address Address, type String, payload byte[], timeout Duration, executor Executor) : CompletableFuture<byte[]> in class io.atomix.cluster.messaging.impl.NettyMessagingService |
From |
To |
|
Change Variable Type response : InternalReply to response : ProtocolReply in method public reply(message ProtocolRequest, status ProtocolReply.Status, payload Optional<byte[]>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteServerConnection |
From |
To |
|
Change Variable Type status : InternalReply.Status to status : ProtocolReply.Status in method protected decode(context ChannelHandlerContext, buffer ByteBuf, out List<Object>) : void in class io.atomix.cluster.messaging.impl.MessageDecoderV1 |
From |
To |
|
Change Variable Type message : InternalRequest to message : ProtocolRequest in method protected decode(context ChannelHandlerContext, buffer ByteBuf, out List<Object>) : void in class io.atomix.cluster.messaging.impl.MessageDecoderV1 |
From |
To |
|
Change Variable Type status : InternalReply.Status to status : ProtocolReply.Status in method public registerHandler(type String, handler BiFunction<Address,byte[],byte[]>, executor Executor) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService |
From |
To |
|
Change Variable Type handler : BiConsumer<InternalRequest,ServerConnection> to handler : BiConsumer<ProtocolRequest,ServerConnection> in method public sendAsync(message ProtocolRequest) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.NettyMessagingService.LocalClientConnection |
From |
To |
|
Change Variable Type handler : BiConsumer<InternalRequest,ServerConnection> to handler : BiConsumer<ProtocolRequest,ServerConnection> in method public sendAndReceive(message ProtocolRequest, timeout Duration) : CompletableFuture<byte[]> in class io.atomix.cluster.messaging.impl.NettyMessagingService.LocalClientConnection |
From |
To |
|
Change Variable Type handler : BiConsumer<InternalRequest,ServerConnection> to handler : BiConsumer<ProtocolRequest,ServerConnection> in method private dispatch(message ProtocolRequest) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.RemoteServerConnection |
From |
To |
|
Change Variable Type message : InternalRequest to message : ProtocolRequest in method public sendAsync(address Address, type String, payload byte[]) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.NettyMessagingService |
From |
To |
|
Change Variable Type connection : ClientConnection to connection : RemoteClientConnection in method private getChannel(address Address, messageType String) : CompletableFuture<Channel> in class io.atomix.cluster.messaging.impl.NettyMessagingService |
From |
To |
|
Change Variable Type message : InternalMessage to message : ProtocolMessage in method protected channelRead0(ctx ChannelHandlerContext, rawMessage Object) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService.InboundMessageDispatcher |
From |
To |
|
Change Variable Type status : InternalReply.Status to status : ProtocolReply.Status in method public registerHandler(type String, handler BiFunction<Address,byte[],CompletableFuture<byte[]>>) : void in class io.atomix.cluster.messaging.impl.NettyMessagingService |
From |
To |