|
Rename Method public communicator() : ClusterCommunicationService renamed to public eventingService() : ClusterEventingService in class io.atomix.Atomix |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Rename Method public state() : State renamed to public getState() : State in class io.atomix.cluster.Node |
From |
To |
|
Rename Method public removeSubscriber(subject MessageSubject) : void renamed to public unsubscribe(subject String) : void in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Rename Method public partitions() : PartitionService renamed to public partitionService() : PartitionService in class io.atomix.Atomix |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Method public removeSubscriber(subject MessageSubject) : void renamed to public unsubscribe(subject String) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Rename Method public removeSubscriber(subject MessageSubject) : void renamed to public unsubscribe(subject String) : void in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Rename Method public cluster() : ClusterService renamed to public clusterService() : ClusterService in class io.atomix.Atomix |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, handler Function<M,R>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, handler Function<M,R>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, handler Function<M,R>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, handler Function<M,R>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Void> renamed to public subscribe(subject String, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Rename Method public state() : State renamed to public getState() : State in class io.atomix.cluster.impl.StatefulNode |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Void> renamed to public subscribe(subject String, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, handler Consumer<M>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Rename Method public primitives() : PrimitivesService renamed to public primitivesService() : PrimitivesService in class io.atomix.Atomix |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Method public metadata() : ClusterMetadataService renamed to public metadataService() : ClusterMetadataService in class io.atomix.Atomix |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, handler Consumer<M>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Method public addSubscriber(subject MessageSubject, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> renamed to public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private doUnicast(subject String, payload byte[], toNodeId NodeId) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public ClusterMessage(sender NodeId, subject String, payload byte[]) in class io.atomix.cluster.messaging.impl.ClusterMessage |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unsubscribe(subject String) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method public PrimaryBackupClientCommunicator(prefix String, serializer Serializer, clusterCommunicator ClusterMessagingService) in class io.atomix.protocols.backup.partition.impl.PrimaryBackupClientCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public multicast(subject String, message M, encoder Function<M,byte[]>, nodes Set<NodeId>) : void in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type clusterEventService : ManagedClusterEventsService to clusterEventingService : ManagedClusterEventingService in method protected Atomix(messagingService ManagedMessagingService, metadataService ManagedClusterMetadataService, cluster ManagedClusterService, clusterMessagingService ManagedClusterMessagingService, clusterEventingService ManagedClusterEventingService, corePartitionGroup ManagedPartitionGroup, partitions ManagedPartitionService, primitiveTypes PrimitiveTypeRegistry) in class io.atomix.Atomix |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method protected buildClusterEventService(clusterService ClusterService, clusterCommunicator ClusterMessagingService) : ManagedClusterEventingService in class io.atomix.Atomix.Builder |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public multicast(subject String, message M, encoder Function<M,byte[]>, nodeIds Set<NodeId>) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method public RaftClientCommunicator(prefix String, serializer Serializer, clusterCommunicator ClusterMessagingService) in class io.atomix.protocols.raft.partition.impl.RaftClientCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in method public subscribe(subject String, communicationService ClusterMessagingService, events EventManager, response AsyncResponse) : void in class io.atomix.rest.resources.MessagesResource |
From |
To |
|
Change Parameter Type eventService : ClusterEventsService to eventService : ClusterEventingService in method public publish(subject String, eventService ClusterEventingService, body String) : Response in class io.atomix.rest.resources.EventsResource |
From |
To |
|
Change Parameter Type clusterCommunicator : ManagedClusterCommunicationService to clusterCommunicator : ManagedClusterMessagingService in method package TestAtomix(messagingService ManagedMessagingService, metadataService ManagedClusterMetadataService, clusterService ManagedClusterService, clusterCommunicator ManagedClusterMessagingService, clusterEventService ManagedClusterEventingService, corePartitionGroup ManagedPartitionGroup, partitions ManagedPartitionService, primitiveTypes PrimitiveTypeRegistry) in class io.atomix.AbstractAtomixTest.TestAtomix |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcast(subject String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private setSubscriberIterator(subject String) : void in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public send(subject String, message M, toNodeId NodeId) : CompletableFuture<R> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unicast(subject String, message M, encoder Function<M,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private getNextNodeId(subject String) : NodeId in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unsubscribe(subject String) : void in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method public RaftClientCommunicator(serializer Serializer, clusterCommunicator ClusterMessagingService) in class io.atomix.protocols.raft.partition.impl.RaftClientCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private sendAndReceive(subject String, request T, nodeId NodeId) : CompletableFuture<U> in class io.atomix.protocols.backup.partition.impl.PrimaryBackupClientCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in method public DefaultPartitionManagementService(metadataService ClusterMetadataService, clusterService ClusterService, communicationService ClusterMessagingService, primitiveTypes PrimitiveTypeRegistry, electionService PrimaryElectionService, sessionIdService SessionIdService) in class io.atomix.primitive.partition.impl.DefaultPartitionManagementService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unicast(subject String, message M, encoder Function<M,byte[]>, toNodeId NodeId) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to messagingService : ClusterMessagingService in method public DefaultClusterEventingService(clusterService ClusterService, messagingService ClusterMessagingService) in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, handler Function<M,R>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public send(subject String, message M, encoder Function<M,byte[]>, decoder Function<byte[],R>) : CompletableFuture<R> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unicast(subject String, message M, encoder Function<M,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unicast(subject String, message M, encoder Function<M,byte[]>, toNodeId NodeId) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in method public next(subject String, communicationService ClusterMessagingService, events EventManager, response AsyncResponse) : void in class io.atomix.rest.resources.MessagesResource |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcast(subject String, message M) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcast(subject String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public send(subject String, message M, encoder Function<M,byte[]>, decoder Function<byte[],R>, toNodeId NodeId) : CompletableFuture<R> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private sendAndReceive(subject String, request T, nodeId NodeId) : CompletableFuture<U> in class io.atomix.protocols.backup.partition.impl.PrimaryBackupServerCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type eventService : ClusterEventsService to eventService : ClusterEventingService in method public CorePrimitivesService(clusterService ClusterService, communicationService ClusterMessagingService, eventService ClusterEventingService, partitionService PartitionService) in class io.atomix.impl.CorePrimitivesService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private registerSubscriber(subject String) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type eventService : ClusterEventsService to eventService : ClusterEventingService in method public CorePrimitiveManagementService(clusterService ClusterService, communicationService ClusterMessagingService, eventService ClusterEventingService, partitionService PartitionService) in class io.atomix.impl.CorePrimitiveManagementService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public send(subject String, message M, encoder Function<M,byte[]>, decoder Function<byte[],R>, toNodeId NodeId) : CompletableFuture<R> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public multicast(subject String, message M, nodeIds Set<NodeId>) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcast(subject String, message M) : void in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcast(subject String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public send(subject String, message M, encoder Function<M,byte[]>, decoder Function<byte[],R>) : CompletableFuture<R> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in method public CorePrimitivesService(clusterService ClusterService, communicationService ClusterMessagingService, eventService ClusterEventingService, partitionService PartitionService) in class io.atomix.impl.CorePrimitivesService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method public RaftServerCommunicator(serializer Serializer, clusterCommunicator ClusterMessagingService) in class io.atomix.protocols.raft.partition.impl.RaftServerCommunicator |
From |
To |
|
Change Parameter Type clusterEventService : ManagedClusterEventsService to clusterEventService : ManagedClusterEventingService in method package TestAtomix(messagingService ManagedMessagingService, metadataService ManagedClusterMetadataService, clusterService ManagedClusterService, clusterCommunicator ManagedClusterMessagingService, clusterEventService ManagedClusterEventingService, corePartitionGroup ManagedPartitionGroup, partitions ManagedPartitionService, primitiveTypes PrimitiveTypeRegistry) in class io.atomix.AbstractAtomixTest.TestAtomix |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private sendAndReceive(subject String, payload byte[], toNodeId NodeId) : CompletableFuture<byte[]> in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private getSubscriberNodes(subject String) : Collection<? extends NodeId> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unsubscribe(subject String) : void in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private Subscription(nodeId NodeId, subject String, logicalTimestamp LogicalTimestamp, tombstone boolean) in class io.atomix.cluster.messaging.impl.Subscription |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public send(subject String, message M) : CompletableFuture<R> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method public RaftServerCommunicator(prefix String, serializer Serializer, clusterCommunicator ClusterMessagingService) in class io.atomix.protocols.raft.partition.impl.RaftServerCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private sendAndReceive(subject String, request T, nodeId NodeId) : CompletableFuture<U> in class io.atomix.protocols.raft.partition.impl.RaftClientCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unicast(subject String, message M) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in method public publish(subject String, communicationService ClusterMessagingService, body String) : Response in class io.atomix.rest.resources.MessagesResource |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method public RaftPartitionServer(partition RaftPartition, localNodeId NodeId, clusterCommunicator ClusterMessagingService, primitiveTypes PrimitiveTypeRegistry) in class io.atomix.protocols.raft.partition.impl.RaftPartitionServer |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public unicast(subject String, message M, toNodeId NodeId) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcastIncludeSelf(subject String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ManagedClusterCommunicationService to clusterMessagingService : ManagedClusterMessagingService in method protected Atomix(messagingService ManagedMessagingService, metadataService ManagedClusterMetadataService, cluster ManagedClusterService, clusterMessagingService ManagedClusterMessagingService, clusterEventingService ManagedClusterEventingService, corePartitionGroup ManagedPartitionGroup, partitions ManagedPartitionService, primitiveTypes PrimitiveTypeRegistry) in class io.atomix.Atomix |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcastIncludeSelf(subject String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcast(subject String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.impl.DefaultClusterMessagingService |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method package Subscription(nodeId NodeId, subject String, logicalTimestamp LogicalTimestamp) in class io.atomix.cluster.messaging.impl.Subscription |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public broadcastIncludeSelf(subject String, message M) : void in class io.atomix.cluster.messaging.ClusterMessagingService |
From |
To |
|
Change Parameter Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in method public PrimaryBackupServerCommunicator(prefix String, serializer Serializer, clusterCommunicator ClusterMessagingService) in class io.atomix.protocols.backup.partition.impl.PrimaryBackupServerCommunicator |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, handler Function<M,R>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Parameter Type eventService : ClusterEventsService to eventService : ClusterEventingService in method public subscribe(subject String, eventService ClusterEventingService, events EventManager, response AsyncResponse) : void in class io.atomix.rest.resources.EventsResource |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private sendAndReceive(subject String, request T, nodeId NodeId) : CompletableFuture<U> in class io.atomix.protocols.raft.partition.impl.RaftServerCommunicator |
From |
To |
|
Change Parameter Type eventService : ClusterEventsService to eventService : ClusterEventingService in method public next(subject String, eventService ClusterEventingService, events EventManager, response AsyncResponse) : void in class io.atomix.rest.resources.EventsResource |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method private unregisterSubscriber(subject String) : void in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in method public send(subject String, node String, communicationService ClusterMessagingService, body String, response AsyncResponse) : void in class io.atomix.rest.resources.MessagesResource |
From |
To |
|
Change Parameter Type subject : MessageSubject to subject : String in method public subscribe(subject String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Parameter Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in method public CorePrimitiveManagementService(clusterService ClusterService, communicationService ClusterMessagingService, eventService ClusterEventingService, partitionService PartitionService) in class io.atomix.impl.CorePrimitiveManagementService |
From |
To |
|
Change Attribute Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in class io.atomix.protocols.raft.partition.impl.RaftPartitionServer |
From |
To |
|
Change Attribute Type leaveSubject : MessageSubject to leaveSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type eventService : ClusterEventsService to eventService : ClusterEventingService in class io.atomix.impl.CorePrimitiveManagementService |
From |
To |
|
Change Attribute Type subject : MessageSubject to subject : String in class io.atomix.cluster.messaging.impl.Subscription |
From |
To |
|
Change Attribute Type metadataSubject : MessageSubject to metadataSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in class io.atomix.protocols.raft.partition.impl.RaftServerCommunicator |
From |
To |
|
Change Attribute Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in class io.atomix.protocols.backup.partition.impl.PrimaryBackupServerCommunicator |
From |
To |
|
Change Attribute Type keepAliveSubject : MessageSubject to keepAliveSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type subject : MessageSubject to subject : String in class io.atomix.cluster.messaging.impl.ClusterMessage |
From |
To |
|
Change Attribute Type heartbeatSubject : MessageSubject to heartbeatSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type installSubject : MessageSubject to installSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in class io.atomix.primitive.partition.impl.DefaultPartitionManagementService |
From |
To |
|
Change Attribute Type appendSubject : MessageSubject to appendSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type querySubject : MessageSubject to querySubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type openSessionSubject : MessageSubject to openSessionSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type backupSubject : MessageSubject to backupSubject : String in class io.atomix.protocols.backup.partition.impl.PrimaryBackupMessageContext |
From |
To |
|
Change Attribute Type clusterCommunicator : ClusterCommunicationService to messagingService : ClusterMessagingService in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Attribute Type subjectIterators : Map<MessageSubject,SubscriberIterator> to subjectIterators : Map<String,SubscriberIterator> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Attribute Type restoreSubject : MessageSubject to restoreSubject : String in class io.atomix.protocols.backup.partition.impl.PrimaryBackupMessageContext |
From |
To |
|
Change Attribute Type communicationService : ClusterCommunicationService to communicationService : ClusterMessagingService in class io.atomix.impl.CorePrimitiveManagementService |
From |
To |
|
Change Attribute Type metadataSubject : MessageSubject to metadataSubject : String in class io.atomix.protocols.backup.partition.impl.PrimaryBackupMessageContext |
From |
To |
|
Change Attribute Type reconfigureSubject : MessageSubject to reconfigureSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type joinSubject : MessageSubject to joinSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type clusterEventService : ManagedClusterEventsService to clusterEventingService : ManagedClusterEventingService in class io.atomix.Atomix |
From |
To |
|
Change Attribute Type subjectSubscriptions : Map<MessageSubject,Map<NodeId,Subscription>> to subjectSubscriptions : Map<String,Map<NodeId,Subscription>> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Attribute Type commandSubject : MessageSubject to commandSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type transferSubject : MessageSubject to transferSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in class io.atomix.protocols.raft.partition.impl.RaftClientCommunicator |
From |
To |
|
Change Attribute Type clusterCommunicator : ClusterCommunicationService to clusterCommunicator : ClusterMessagingService in class io.atomix.protocols.backup.partition.impl.PrimaryBackupClientCommunicator |
From |
To |
|
Change Attribute Type closeSessionSubject : MessageSubject to closeSessionSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type GOSSIP_MESSAGE_SUBJECT : MessageSubject to GOSSIP_MESSAGE_SUBJECT : String in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Attribute Type voteSubject : MessageSubject to voteSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type configureSubject : MessageSubject to configureSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type executeSubject : MessageSubject to executeSubject : String in class io.atomix.protocols.backup.partition.impl.PrimaryBackupMessageContext |
From |
To |
|
Change Attribute Type pollSubject : MessageSubject to pollSubject : String in class io.atomix.protocols.raft.partition.impl.RaftMessageContext |
From |
To |
|
Change Attribute Type closeSubject : MessageSubject to closeSubject : String in class io.atomix.protocols.backup.partition.impl.PrimaryBackupMessageContext |
From |
To |
|
Change Attribute Type clusterCommunicator : ManagedClusterCommunicationService to clusterMessagingService : ManagedClusterMessagingService in class io.atomix.Atomix |
From |
To |