|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, handler Consumer<M>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Return Type Response to void in method public delete(subject String, eventService ClusterEventingService, events EventManager, response AsyncResponse) : void in class io.atomix.rest.resources.EventsResource |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, handler Function<M,R>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Return Type Collection<? extends NodeId> to Stream<NodeId> in method private getSubscriberNodes(topic String) : Stream<NodeId> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Return Type NodeId to SubscriptionMetadata in method public next() : SubscriptionMetadata in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService.TopicIterator |
From |
To |
|
Change Return Type Response to void in method public unsubscribe(subject String, id String, eventService ClusterEventingService, events EventManager, response AsyncResponse) : void in class io.atomix.rest.resources.EventsResource |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Change Return Type CompletableFuture<Void> to CompletableFuture<Subscription> in method public subscribe(topic String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Change Return Type Subscription to SubscriptionMetadata in method public asTombstone() : SubscriptionMetadata in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService.SubscriptionMetadata |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, handler Function<M,R>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter nodeId : NodeId to node : Node in method private updateNode(node Node) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, handler Function<M,CompletableFuture<R>>) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public send(topic String, message M, encoder Function<M,byte[]>, decoder Function<byte[],R>) : CompletableFuture<R> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, decoder Function<byte[],M>, handler Consumer<M>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, handler Consumer<M>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public send(topic String, message M) : CompletableFuture<R> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public broadcast(topic String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter clusterCommunicator : ClusterMessagingService to messagingService : MessagingService in method protected buildClusterEventService(clusterService ClusterService, messagingService MessagingService) : ManagedClusterEventingService in class io.atomix.Atomix.Builder |
From |
To |
|
Rename Parameter subject : String to topic : String in method private getNextNodeId(topic String) : NodeId in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,R>, encoder Function<R,byte[]>, executor Executor) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public send(topic String, message M, encoder Function<M,byte[]>, decoder Function<byte[],R>) : CompletableFuture<R> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method package SubscriptionMetadata(nodeId NodeId, topic String, logicalTimestamp LogicalTimestamp) in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService.SubscriptionMetadata |
From |
To |
|
Rename Parameter subject : String to topic : String in method public broadcast(topic String, message M) : void in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public unicast(topic String, message M, encoder Function<M,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public unicast(topic String, message M) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public subscribe(topic String, decoder Function<byte[],M>, handler Function<M,CompletableFuture<R>>, encoder Function<R,byte[]>) : CompletableFuture<Subscription> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method private getSubscriberNodes(topic String) : Stream<NodeId> in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public broadcast(topic String, message M, encoder Function<M,byte[]>) : void in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method package SubscriptionMetadata(nodeId NodeId, topic String, logicalTimestamp LogicalTimestamp, tombstone boolean) in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService.SubscriptionMetadata |
From |
To |
|
Rename Parameter subject : String to topic : String in method private setSubscriberIterator(topic String) : void in class io.atomix.cluster.messaging.impl.DefaultClusterEventingService |
From |
To |
|
Rename Parameter subject : String to topic : String in method public unicast(topic String, message M, encoder Function<M,byte[]>) : CompletableFuture<Void> in class io.atomix.cluster.messaging.ClusterEventingService |
From |
To |