|
Change Parameter Type pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method public CatchupServer(logProvider LogProvider, userLogProvider LogProvider, storeIdSupplier Supplier<StoreId>, transactionIdStoreSupplier Supplier<TransactionIdStore>, logicalTransactionStoreSupplier Supplier<LogicalTransactionStore>, dataSourceSupplier Supplier<NeoStoreDataSource>, dataSourceAvailabilitySupplier BooleanSupplier, snapshotService CoreSnapshotService, config Config, monitors Monitors, checkPointerSupplier Supplier<CheckPointer>, fs FileSystemAbstraction, pageCache PageCache, storeCopyCheckPointMutex StoreCopyCheckPointMutex, pipelineWrapper PipelineWrapper) in class org.neo4j.causalclustering.catchup.CatchupServer |
From |
To |
|
Change Parameter Type pipelineHandlerAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method package initChannel(ch SocketChannel, handler CatchUpResponseHandler, logProvider LogProvider, monitors Monitors, pipelineWrapper PipelineWrapper) : void in class org.neo4j.causalclustering.catchup.CatchUpClientChannelPipeline |
From |
To |
|
Change Parameter Type timestampedLazyChannel : NonBlockingChannel to timestampedLazyChannel : ReconnectingChannel in method public putIfAbsent(to AdvertisedSocketAddress, timestampedLazyChannel ReconnectingChannel) : ReconnectingChannel in class org.neo4j.causalclustering.messaging.ReconnectingChannels |
From |
To |
|
Change Parameter Type channelInitializer : ChannelInitializer<SocketChannel> to channelInitializer : ChannelInitializer in method public SenderService(channelInitializer ChannelInitializer, logProvider LogProvider, monitors Monitors) in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Parameter Type promise : Promise<?> to promise : CompletableFuture<Void> in method private deferredWrite(msg Object, channelFuture ChannelFuture, promise CompletableFuture<Void>, firstAttempt boolean, writer BiFunction<io.netty.channel.Channel,Object,Future<Void>>) : void in class org.neo4j.causalclustering.messaging.ReconnectingChannel |
From |
To |
|
Change Parameter Type pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method public CatchUpClient(logProvider LogProvider, clock Clock, inactivityTimeoutMillis long, monitors Monitors, pipelineWrapper PipelineWrapper) in class org.neo4j.causalclustering.catchup.CatchUpClient |
From |
To |
|
Change Parameter Type nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in method public IdleChannelReaperHandler(channels ReconnectingChannels) in class org.neo4j.causalclustering.messaging.IdleChannelReaperHandler |
From |
To |
|
Change Parameter Type pipelineHandlerAppender : PipelineHandlerAppender to pipelineBuilderFactory : NettyPipelineBuilderFactory in method package RaftServerModule(platformModule PlatformModule, consensusModule ConsensusModule, identityModule IdentityModule, coreServerModule CoreServerModule, localDatabase LocalDatabase, pipelineBuilderFactory NettyPipelineBuilderFactory, messageLogger MessageLogger<MemberId>) in class org.neo4j.causalclustering.core.RaftServerModule |
From |
To |
|
Rename Variable nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in method public shouldRemoveChannelViaCallback() : void in class org.neo4j.causalclustering.messaging.IdleChannelReaperHandlerTest |
From |
To |
|
Rename Variable pipelineHandlerAppender : PipelineHandlerAppender to clientPipelineWrapper : PipelineWrapper in method package EnterpriseCoreEditionModule(platformModule PlatformModule, discoveryServiceFactory DiscoveryServiceFactory) in class org.neo4j.causalclustering.core.EnterpriseCoreEditionModule |
From |
To |
|
Rename Variable appenderFactory : PipelineHandlerAppenderFactory to pipelineWrapperFactory : DuplexPipelineWrapperFactory in method package EnterpriseReadReplicaEditionModule(platformModule PlatformModule, discoveryServiceFactory DiscoveryServiceFactory, myself MemberId) in class org.neo4j.causalclustering.readreplica.EnterpriseReadReplicaEditionModule |
From |
To |
|
Rename Variable pipelineHandlerAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method private backupDelegatorFromConfig(pageCache PageCache, config Config) : BackupDelegator in class org.neo4j.backup.impl.BackupSupportingClassesFactory |
From |
To |
|
Rename Variable nonBlockingChannel : NonBlockingChannel to channel : ReconnectingChannel in method private channel(destination AdvertisedSocketAddress) : Channel in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Return Type PipelineHandlerAppenderFactory to DuplexPipelineWrapperFactory in method protected pipelineWrapperFactory() : DuplexPipelineWrapperFactory in class org.neo4j.causalclustering.core.EnterpriseCoreEditionModule |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method private doWrite(msg Object, writer BiFunction<io.netty.channel.Channel,Object,Future<Void>>) : CompletableFuture<Void> in class org.neo4j.causalclustering.messaging.ReconnectingChannel |
From |
To |
|
Change Return Type NonBlockingChannel to ReconnectingChannel in method public get(to AdvertisedSocketAddress) : ReconnectingChannel in class org.neo4j.causalclustering.messaging.ReconnectingChannels |
From |
To |
|
Change Return Type NonBlockingChannel to Channel in method private channel(destination AdvertisedSocketAddress) : Channel in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Return Type NonBlockingChannel to ReconnectingChannel in method public putIfAbsent(to AdvertisedSocketAddress, timestampedLazyChannel ReconnectingChannel) : ReconnectingChannel in class org.neo4j.causalclustering.messaging.ReconnectingChannels |
From |
To |
|
Change Return Type Collection<NonBlockingChannel> to Collection<ReconnectingChannel> in method public values() : Collection<ReconnectingChannel> in class org.neo4j.causalclustering.messaging.ReconnectingChannels |
From |
To |
|
Change Return Type PipelineHandlerAppenderFactory to DuplexPipelineWrapperFactory in method protected pipelineWrapperFactory() : DuplexPipelineWrapperFactory in class org.neo4j.causalclustering.readreplica.EnterpriseReadReplicaEditionModule |
From |
To |
|
Rename Attribute nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Rename Attribute pipelineHandlerAppender : PipelineHandlerAppender to pipelineBuilderFactory : NettyPipelineBuilderFactory in class org.neo4j.causalclustering.core.RaftServerModule |
From |
To |
|
Rename Attribute nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in class org.neo4j.causalclustering.messaging.IdleChannelReaperHandler |
From |
To |
|
Rename Attribute pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in class org.neo4j.causalclustering.catchup.CatchUpClient |
From |
To |
|
Rename Attribute pipelineAppender : PipelineHandlerAppender to clientPipelineWrapper : PipelineWrapper in class org.neo4j.causalclustering.core.server.CoreServerModule |
From |
To |
|
Rename Attribute pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in class org.neo4j.causalclustering.catchup.CatchupServer |
From |
To |
|
Change Variable Type fSend : Future<Void> to fSend : CompletableFuture<Void> in method public shouldBeAbleToSendMessage() : void in class org.neo4j.causalclustering.messaging.ReconnectingChannelIT |
From |
To |
|
Change Variable Type appenderFactory : PipelineHandlerAppenderFactory to pipelineWrapperFactory : DuplexPipelineWrapperFactory in method package EnterpriseReadReplicaEditionModule(platformModule PlatformModule, discoveryServiceFactory DiscoveryServiceFactory, myself MemberId) in class org.neo4j.causalclustering.readreplica.EnterpriseReadReplicaEditionModule |
From |
To |
|
Change Variable Type nonBlockingChannel : NonBlockingChannel to channel : ReconnectingChannel in method private channel(destination AdvertisedSocketAddress) : Channel in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Variable Type itr : Iterator<NonBlockingChannel> to itr : Iterator<ReconnectingChannel> in method public stop() : void in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Variable Type existingNonBlockingChannel : NonBlockingChannel to existingNonBlockingChannel : ReconnectingChannel in method private channel(destination AdvertisedSocketAddress) : Channel in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Variable Type fSend : Future<Void> to fSend : CompletableFuture<Void> in method public shouldFailSendWhenNoServer() : void in class org.neo4j.causalclustering.messaging.ReconnectingChannelIT |
From |
To |
|
Change Variable Type fSend : Future<Void> to fSend : CompletableFuture<Void> in method public shouldNotAllowSendingOnDisposedChannel() : void in class org.neo4j.causalclustering.messaging.ReconnectingChannelIT |
From |
To |
|
Change Variable Type fSend : Future<Void> to fSend : CompletableFuture<Void> in method public shouldReconnectAfterServerComesBack() : void in class org.neo4j.causalclustering.messaging.ReconnectingChannelIT |
From |
To |
|
Change Variable Type nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in method public shouldRemoveChannelViaCallback() : void in class org.neo4j.causalclustering.messaging.IdleChannelReaperHandlerTest |
From |
To |
|
Change Variable Type timestampedChannel : NonBlockingChannel to timestampedChannel : Channel in method public stop() : void in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Variable Type pipelineHandlerAppender : PipelineHandlerAppender to clientPipelineWrapper : PipelineWrapper in method package EnterpriseCoreEditionModule(platformModule PlatformModule, discoveryServiceFactory DiscoveryServiceFactory) in class org.neo4j.causalclustering.core.EnterpriseCoreEditionModule |
From |
To |
|
Change Variable Type fSend : Future<Void> to fSend : CompletableFuture<Void> in method public shouldAllowDeferredSend() : void in class org.neo4j.causalclustering.messaging.ReconnectingChannelIT |
From |
To |
|
Change Variable Type pipelineHandlerAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method private backupDelegatorFromConfig(pageCache PageCache, config Config) : BackupDelegator in class org.neo4j.backup.impl.BackupSupportingClassesFactory |
From |
To |
|
Change Attribute Type channelInitializer : ChannelInitializer<SocketChannel> to channelInitializer : ChannelInitializer in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Attribute Type pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in class org.neo4j.causalclustering.catchup.CatchupServer |
From |
To |
|
Change Attribute Type lazyChannelMap : ConcurrentHashMap<AdvertisedSocketAddress,NonBlockingChannel> to lazyChannelMap : ConcurrentHashMap<AdvertisedSocketAddress,ReconnectingChannel> in class org.neo4j.causalclustering.messaging.ReconnectingChannels |
From |
To |
|
Change Attribute Type channel : NonBlockingChannel to channel : ReconnectingChannel in class org.neo4j.causalclustering.messaging.ReconnectingChannelIT |
From |
To |
|
Change Attribute Type nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Change Attribute Type pipelineHandlerAppender : PipelineHandlerAppender to pipelineBuilderFactory : NettyPipelineBuilderFactory in class org.neo4j.causalclustering.core.RaftServerModule |
From |
To |
|
Change Attribute Type nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in class org.neo4j.causalclustering.messaging.IdleChannelReaperHandler |
From |
To |
|
Change Attribute Type pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in class org.neo4j.causalclustering.catchup.CatchUpClient |
From |
To |
|
Change Attribute Type pipelineAppender : PipelineHandlerAppender to clientPipelineWrapper : PipelineWrapper in class org.neo4j.causalclustering.core.server.CoreServerModule |
From |
To |
|
Rename Parameter to : AdvertisedSocketAddress to destination : AdvertisedSocketAddress in method private channel(destination AdvertisedSocketAddress) : Channel in class org.neo4j.causalclustering.messaging.SenderService |
From |
To |
|
Rename Parameter pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method public CatchUpClient(logProvider LogProvider, clock Clock, inactivityTimeoutMillis long, monitors Monitors, pipelineWrapper PipelineWrapper) in class org.neo4j.causalclustering.catchup.CatchUpClient |
From |
To |
|
Rename Parameter nonBlockingChannels : NonBlockingChannels to channels : ReconnectingChannels in method public IdleChannelReaperHandler(channels ReconnectingChannels) in class org.neo4j.causalclustering.messaging.IdleChannelReaperHandler |
From |
To |
|
Rename Parameter pipelineHandlerAppender : PipelineHandlerAppender to pipelineBuilderFactory : NettyPipelineBuilderFactory in method package RaftServerModule(platformModule PlatformModule, consensusModule ConsensusModule, identityModule IdentityModule, coreServerModule CoreServerModule, localDatabase LocalDatabase, pipelineBuilderFactory NettyPipelineBuilderFactory, messageLogger MessageLogger<MemberId>) in class org.neo4j.causalclustering.core.RaftServerModule |
From |
To |
|
Rename Parameter pipelineAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method public CatchupServer(logProvider LogProvider, userLogProvider LogProvider, storeIdSupplier Supplier<StoreId>, transactionIdStoreSupplier Supplier<TransactionIdStore>, logicalTransactionStoreSupplier Supplier<LogicalTransactionStore>, dataSourceSupplier Supplier<NeoStoreDataSource>, dataSourceAvailabilitySupplier BooleanSupplier, snapshotService CoreSnapshotService, config Config, monitors Monitors, checkPointerSupplier Supplier<CheckPointer>, fs FileSystemAbstraction, pageCache PageCache, storeCopyCheckPointMutex StoreCopyCheckPointMutex, pipelineWrapper PipelineWrapper) in class org.neo4j.causalclustering.catchup.CatchupServer |
From |
To |
|
Rename Parameter pipelineHandlerAppender : PipelineHandlerAppender to pipelineWrapper : PipelineWrapper in method package initChannel(ch SocketChannel, handler CatchUpResponseHandler, logProvider LogProvider, monitors Monitors, pipelineWrapper PipelineWrapper) : void in class org.neo4j.causalclustering.catchup.CatchUpClientChannelPipeline |
From |
To |
|
Rename Parameter handler : Inbound.MessageHandler<RaftMessages.ReceivedInstantClusterIdAwareMessage> to actual : Inbound.MessageHandler<RaftMessages.ReceivedInstantClusterIdAwareMessage> in method public registerHandler(actual Inbound.MessageHandler<RaftMessages.ReceivedInstantClusterIdAwareMessage>) : void in class org.neo4j.causalclustering.core.consensus.RaftMessageNettyHandler |
From |
To |