|
Change Parameter Type batch : List<RaftMessages.StoreIdAwareMessage> to batch : List<RaftMessages.ClusterIdAwareMessage> in method private drain(messageQueue BlockingQueue<RaftMessages.ClusterIdAwareMessage>, batch List<RaftMessages.ClusterIdAwareMessage>, maxElements int) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Parameter Type message : RaftMessages.StoreIdAwareMessage to message : RaftMessages.ClusterIdAwareMessage in method public handle(message RaftMessages.ClusterIdAwareMessage) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Parameter Type decoratedMessage : RaftMessages.StoreIdAwareMessage to decoratedMessage : RaftMessages.ClusterIdAwareMessage in method protected encode(ctx ChannelHandlerContext, decoratedMessage RaftMessages.ClusterIdAwareMessage, list List<Object>) : void in class org.neo4j.coreedge.messaging.marshalling.RaftMessageEncoder |
From |
To |
|
Change Parameter Type storeIdAwareMessage : RaftMessages.StoreIdAwareMessage to clusterIdAwareMessage : RaftMessages.ClusterIdAwareMessage in method public handle(clusterIdAwareMessage RaftMessages.ClusterIdAwareMessage) : void in class org.neo4j.coreedge.core.state.CoreState |
From |
To |
|
Change Parameter Type handler : MessageHandler<RaftMessages.StoreIdAwareMessage> to handler : MessageHandler<RaftMessages.ClusterIdAwareMessage> in method public BatchingMessageHandler(handler MessageHandler<RaftMessages.ClusterIdAwareMessage>, queueSize int, maxBatch int, logProvider LogProvider) in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Parameter Type messageQueue : BlockingQueue<RaftMessages.StoreIdAwareMessage> to messageQueue : BlockingQueue<RaftMessages.ClusterIdAwareMessage> in method private drain(messageQueue BlockingQueue<RaftMessages.ClusterIdAwareMessage>, batch List<RaftMessages.ClusterIdAwareMessage>, maxElements int) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Parameter Type storeIdAwareMessage : RaftMessages.StoreIdAwareMessage to clusterIdAwareMessage : RaftMessages.ClusterIdAwareMessage in method protected channelRead0(channelHandlerContext ChannelHandlerContext, clusterIdAwareMessage RaftMessages.ClusterIdAwareMessage) : void in class org.neo4j.coreedge.core.consensus.RaftServer.RaftMessageHandler |
From |
To |
|
Change Parameter Type storeId : StoreId to clusterId : ClusterId in method public ClusterIdAwareMessage(clusterId ClusterId, message RaftMessage) in class org.neo4j.coreedge.core.consensus.RaftMessages.ClusterIdAwareMessage |
From |
To |
|
Change Parameter Type batch : List<RaftMessages.StoreIdAwareMessage> to batch : List<RaftMessages.ClusterIdAwareMessage> in method private collateAndHandleBatch(batch List<RaftMessages.ClusterIdAwareMessage>) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Parameter Type handler : Inbound.MessageHandler<RaftMessages.StoreIdAwareMessage> to handler : Inbound.MessageHandler<RaftMessages.ClusterIdAwareMessage> in method public registerHandler(handler Inbound.MessageHandler<RaftMessages.ClusterIdAwareMessage>) : void in class org.neo4j.coreedge.core.consensus.RaftServer |
From |
To |
|
Change Parameter Type localDatabase : LocalDatabase to clusterIdentity : ClusterIdentity in method public RaftOutbound(discoveryService CoreTopologyService, outbound Outbound<AdvertisedSocketAddress,Message>, clusterIdentity ClusterIdentity, logProvider LogProvider, logThresholdMillis long) in class org.neo4j.coreedge.messaging.RaftOutbound |
From |
To |
|
Rename Variable storeIdAwareMessage : RaftMessages.StoreIdAwareMessage to clusterIdAwareMessage : RaftMessages.ClusterIdAwareMessage in method private drain(messageQueue BlockingQueue<RaftMessages.ClusterIdAwareMessage>, batch List<RaftMessages.ClusterIdAwareMessage>, maxElements int) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Rename Variable raftOutbound : Outbound<MemberId,RaftMessages.RaftMessage> to loggingOutbound : Outbound<MemberId,RaftMessages.RaftMessage> in method package EnterpriseCoreEditionModule(platformModule PlatformModule, discoveryServiceFactory DiscoveryServiceFactory) in class org.neo4j.coreedge.core.EnterpriseCoreEditionModule |
From |
To |
|
Rename Variable storeId : StoreId to clusterId : ClusterId in method protected encode(ctx ChannelHandlerContext, decoratedMessage RaftMessages.ClusterIdAwareMessage, list List<Object>) : void in class org.neo4j.coreedge.messaging.marshalling.RaftMessageEncoder |
From |
To |
|
Rename Variable storeId : StoreId to clusterId : ClusterId in method protected decode(ctx ChannelHandlerContext, buffer ByteBuf, list List<Object>) : void in class org.neo4j.coreedge.messaging.marshalling.RaftMessageDecoder |
From |
To |
|
Rename Variable storeId : StoreId to clusterId : ClusterId in method private collateAndHandleBatch(batch List<RaftMessages.ClusterIdAwareMessage>) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Variable Type binder : BindingService to binder : ClusterIdentity in method public shouldBootstrapWhenBootstrappable() : void in class org.neo4j.coreedge.identity.ClusterIdentityTest |
From |
To |
|
Change Variable Type that : StoreIdAwareMessage to that : ClusterIdAwareMessage in method public equals(o Object) : boolean in class org.neo4j.coreedge.core.consensus.RaftMessages.ClusterIdAwareMessage |
From |
To |
|
Change Variable Type decoratedMessage : RaftMessages.StoreIdAwareMessage to decoratedMessage : RaftMessages.ClusterIdAwareMessage in method private serializeReadBackAndVerifyMessage(message RaftMessages.RaftMessage) : void in class org.neo4j.coreedge.messaging.marshalling.RaftMessageEncodingDecodingTest |
From |
To |
|
Change Variable Type messageD : RaftMessages.StoreIdAwareMessage to messageD : RaftMessages.ClusterIdAwareMessage in method public shouldBatchNewEntriesAndHandleOtherMessagesSingularly() : void in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Variable Type storeIdAwareMessage : RaftMessages.StoreIdAwareMessage to clusterIdAwareMessage : RaftMessages.ClusterIdAwareMessage in method private drain(messageQueue BlockingQueue<RaftMessages.ClusterIdAwareMessage>, batch List<RaftMessages.ClusterIdAwareMessage>, maxElements int) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Variable Type messageB : RaftMessages.StoreIdAwareMessage to messageB : RaftMessages.ClusterIdAwareMessage in method public shouldBatchNewEntriesAndHandleOtherMessagesSingularly() : void in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Variable Type tempDraining : List<RaftMessages.StoreIdAwareMessage> to tempDraining : List<RaftMessages.ClusterIdAwareMessage> in method private drain(messageQueue BlockingQueue<RaftMessages.ClusterIdAwareMessage>, batch List<RaftMessages.ClusterIdAwareMessage>, maxElements int) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Variable Type loggingRaftInbound : LoggingInbound<RaftMessages.StoreIdAwareMessage> to loggingRaftInbound : LoggingInbound<RaftMessages.ClusterIdAwareMessage> in method public CoreServerModule(identityModule IdentityModule, platformModule PlatformModule, consensusModule ConsensusModule, coreStateMachinesModule CoreStateMachinesModule, replicationModule ReplicationModule, clusterStateDirectory File, clusteringModule ClusteringModule, localDatabase LocalDatabase, messageLogger MessageLogger<MemberId>, dbHealthSupplier Supplier<DatabaseHealth>) in class org.neo4j.coreedge.core.server.CoreServerModule |
From |
To |
|
Change Variable Type message : RaftMessages.StoreIdAwareMessage to message : RaftMessages.ClusterIdAwareMessage in method public shouldInvokeHandlerOnQueuedMessage() : void in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Variable Type binder : BindingService to binder : ClusterIdentity in method public shouldPublishStoredClusterIdIfPreviouslyBound() : void in class org.neo4j.coreedge.identity.ClusterIdentityTest |
From |
To |
|
Change Variable Type binder : BindingService to binder : ClusterIdentity in method public shouldTimeoutWhenNotBootrappableAndNobodyElsePublishesClusterId() : void in class org.neo4j.coreedge.identity.ClusterIdentityTest |
From |
To |
|
Change Variable Type message : RaftMessages.StoreIdAwareMessage to message : RaftMessages.ClusterIdAwareMessage in method public shouldSerializeHeartbeats() : void in class org.neo4j.coreedge.messaging.marshalling.RaftMessageEncodingDecodingTest |
From |
To |
|
Change Variable Type storeId : StoreId to clusterId : ClusterId in method private collateAndHandleBatch(batch List<RaftMessages.ClusterIdAwareMessage>) : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Variable Type message : RaftMessages.StoreIdAwareMessage to message : RaftMessages.ClusterIdAwareMessage in method public shouldInvokeInnerHandlerWhenRun() : void in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Variable Type storeId : StoreId to clusterId : ClusterId in method protected decode(ctx ChannelHandlerContext, buffer ByteBuf, list List<Object>) : void in class org.neo4j.coreedge.messaging.marshalling.RaftMessageDecoder |
From |
To |
|
Change Variable Type messageC : RaftMessages.StoreIdAwareMessage to messageC : RaftMessages.ClusterIdAwareMessage in method public shouldBatchNewEntriesAndHandleOtherMessagesSingularly() : void in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Variable Type binder : BindingService to binder : ClusterIdentity in method public shouldFailToPublishMismatchingStoredClusterId() : void in class org.neo4j.coreedge.identity.ClusterIdentityTest |
From |
To |
|
Change Variable Type binder : BindingService to binder : ClusterIdentity in method public shouldBindToClusterIdPublishedByAnotherMember() : void in class org.neo4j.coreedge.identity.ClusterIdentityTest |
From |
To |
|
Change Variable Type message : RaftMessages.StoreIdAwareMessage to message : RaftMessages.ClusterIdAwareMessage in method public run() : void in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Variable Type messageA : RaftMessages.StoreIdAwareMessage to messageA : RaftMessages.ClusterIdAwareMessage in method public shouldBatchNewEntriesAndHandleOtherMessagesSingularly() : void in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Variable Type storeId : StoreId to clusterId : ClusterId in method protected encode(ctx ChannelHandlerContext, decoratedMessage RaftMessages.ClusterIdAwareMessage, list List<Object>) : void in class org.neo4j.coreedge.messaging.marshalling.RaftMessageEncoder |
From |
To |
|
Change Attribute Type storeId : StoreId to clusterId : ClusterId in class org.neo4j.coreedge.core.consensus.RaftMessages.ClusterIdAwareMessage |
From |
To |
|
Change Attribute Type localStoreId : StoreId to localClusterId : ClusterId in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Attribute Type storeId : StoreId to clusterId : ClusterId in class org.neo4j.coreedge.messaging.marshalling.RaftMessageEncodingDecodingTest |
From |
To |
|
Change Attribute Type messageQueue : BlockingQueue<RaftMessages.StoreIdAwareMessage> to messageQueue : BlockingQueue<RaftMessages.ClusterIdAwareMessage> in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Attribute Type messageHandler : MessageHandler<RaftMessages.StoreIdAwareMessage> to messageHandler : MessageHandler<RaftMessages.ClusterIdAwareMessage> in class org.neo4j.coreedge.core.consensus.RaftServer |
From |
To |
|
Change Attribute Type raftStateMachine : MessageHandler<RaftMessages.StoreIdAwareMessage> to raftStateMachine : MessageHandler<RaftMessages.ClusterIdAwareMessage> in class org.neo4j.coreedge.core.server.BatchingMessageHandlerTest |
From |
To |
|
Change Attribute Type handler : MessageHandler<RaftMessages.StoreIdAwareMessage> to handler : MessageHandler<RaftMessages.ClusterIdAwareMessage> in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Attribute Type batch : List<RaftMessages.StoreIdAwareMessage> to batch : List<RaftMessages.ClusterIdAwareMessage> in class org.neo4j.coreedge.core.server.BatchingMessageHandler |
From |
To |
|
Change Attribute Type bindingService : BindingService to clusterIdentity : ClusterIdentity in class org.neo4j.coreedge.core.state.CoreState |
From |
To |
|
Change Attribute Type localDatabase : LocalDatabase to clusterIdentity : ClusterIdentity in class org.neo4j.coreedge.messaging.RaftOutbound |
From |
To |
|
Rename Parameter storeId : StoreId to clusterId : ClusterId in method public ClusterIdAwareMessage(clusterId ClusterId, message RaftMessage) in class org.neo4j.coreedge.core.consensus.RaftMessages.ClusterIdAwareMessage |
From |
To |
|
Rename Parameter localDatabase : LocalDatabase to clusterIdentity : ClusterIdentity in method public RaftOutbound(discoveryService CoreTopologyService, outbound Outbound<AdvertisedSocketAddress,Message>, clusterIdentity ClusterIdentity, logProvider LogProvider, logThresholdMillis long) in class org.neo4j.coreedge.messaging.RaftOutbound |
From |
To |
|
Rename Parameter storeIdAwareMessage : RaftMessages.StoreIdAwareMessage to clusterIdAwareMessage : RaftMessages.ClusterIdAwareMessage in method public handle(clusterIdAwareMessage RaftMessages.ClusterIdAwareMessage) : void in class org.neo4j.coreedge.core.state.CoreState |
From |
To |
|
Rename Parameter storeIdAwareMessage : RaftMessages.StoreIdAwareMessage to clusterIdAwareMessage : RaftMessages.ClusterIdAwareMessage in method protected channelRead0(channelHandlerContext ChannelHandlerContext, clusterIdAwareMessage RaftMessages.ClusterIdAwareMessage) : void in class org.neo4j.coreedge.core.consensus.RaftServer.RaftMessageHandler |
From |
To |