diff --git a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/raft/replication/tx/ExpontentialBackoffStrategy.java b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/raft/replication/tx/ExponentialBackoffStrategy.java similarity index 90% rename from enterprise/core-edge/src/main/java/org/neo4j/coreedge/raft/replication/tx/ExpontentialBackoffStrategy.java rename to enterprise/core-edge/src/main/java/org/neo4j/coreedge/raft/replication/tx/ExponentialBackoffStrategy.java index 7ae23027a90e8..ae6b65abb0689 100644 --- a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/raft/replication/tx/ExpontentialBackoffStrategy.java +++ b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/raft/replication/tx/ExponentialBackoffStrategy.java @@ -21,11 +21,11 @@ import java.util.concurrent.TimeUnit; -public class ExpontentialBackoffStrategy implements RetryStrategy +public class ExponentialBackoffStrategy implements RetryStrategy { private final long initialBackoffTimeMillis; - public ExpontentialBackoffStrategy( long initialBackoffTime, TimeUnit timeUnit ) + public ExponentialBackoffStrategy( long initialBackoffTime, TimeUnit timeUnit ) { initialBackoffTimeMillis = timeUnit.toMillis( initialBackoffTime ); } diff --git a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java index 2ad6cb3aae50d..f09bd62ec3941 100644 --- a/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java +++ b/enterprise/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java @@ -64,7 +64,7 @@ import org.neo4j.coreedge.raft.replication.token.ReplicatedRelationshipTypeTokenHolder; import org.neo4j.coreedge.raft.replication.tx.CommittingTransactions; import org.neo4j.coreedge.raft.replication.tx.CommittingTransactionsRegistry; -import org.neo4j.coreedge.raft.replication.tx.ExpontentialBackoffStrategy; +import org.neo4j.coreedge.raft.replication.tx.ExponentialBackoffStrategy; import org.neo4j.coreedge.raft.replication.tx.ReplicatedTransactionCommitProcess; import org.neo4j.coreedge.raft.replication.tx.ReplicatedTransactionStateMachine; import org.neo4j.coreedge.raft.roles.Role; @@ -386,7 +386,7 @@ public static CommitProcessFactory createCommitProcessFactory( stateMachines.add( replicatedTxStateMachine ); return new ReplicatedTransactionCommitProcess( replicator, localSessionPool, - new ExpontentialBackoffStrategy( 10, TimeUnit.SECONDS ), logging, committingTransactions, monitors + new ExponentialBackoffStrategy( 10, TimeUnit.SECONDS ), logging, committingTransactions, monitors ); }; } diff --git a/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/CommitProcessStateMachineCollaborationTest.java b/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/CommitProcessStateMachineCollaborationTest.java index e81742231818e..122f3f9e8b798 100644 --- a/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/CommitProcessStateMachineCollaborationTest.java +++ b/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/CommitProcessStateMachineCollaborationTest.java @@ -82,7 +82,7 @@ public void shouldAlwaysCompleteFutureEvenIfReplicationHappensAtUnfortunateMomen stateMachines.add( stateMachine ); ReplicatedTransactionCommitProcess commitProcess = new ReplicatedTransactionCommitProcess( - replicator, sessionPool, new ExpontentialBackoffStrategy( 10, SECONDS ), + replicator, sessionPool, new ExponentialBackoffStrategy( 10, SECONDS ), NullLogService.getInstance(), txFutures, new Monitors() ); // when @@ -114,7 +114,7 @@ public void shouldFailTransactionIfLockSessionChanges() throws Exception stateMachines.add( stateMachine ); ReplicatedTransactionCommitProcess commitProcess = new ReplicatedTransactionCommitProcess( - replicator, sessionPool, new ExpontentialBackoffStrategy( 10, SECONDS ), + replicator, sessionPool, new ExponentialBackoffStrategy( 10, SECONDS ), NullLogService.getInstance(), txFutures, new Monitors() ); // when diff --git a/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/ExpontentialBackoffStrategyTest.java b/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/ExponentialBackoffStrategyTest.java similarity index 88% rename from enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/ExpontentialBackoffStrategyTest.java rename to enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/ExponentialBackoffStrategyTest.java index 306c427c7c55a..26706e12c16e4 100644 --- a/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/ExpontentialBackoffStrategyTest.java +++ b/enterprise/core-edge/src/test/java/org/neo4j/coreedge/raft/replication/tx/ExponentialBackoffStrategyTest.java @@ -25,7 +25,7 @@ import static org.junit.Assert.assertEquals; -public class ExpontentialBackoffStrategyTest +public class ExponentialBackoffStrategyTest { private static final int NUMBER_OF_ACCESSES = 5; @@ -33,7 +33,7 @@ public class ExpontentialBackoffStrategyTest public void shouldDoubleEachTime() throws Exception { // given - ExpontentialBackoffStrategy strategy = new ExpontentialBackoffStrategy( 1, MILLISECONDS ); + ExponentialBackoffStrategy strategy = new ExponentialBackoffStrategy( 1, MILLISECONDS ); RetryStrategy.Timeout timeout = strategy.newTimeout(); // when @@ -50,7 +50,7 @@ public void shouldDoubleEachTime() throws Exception public void shouldProvidePreviousTimeout() throws Exception { // given - ExpontentialBackoffStrategy strategy = new ExpontentialBackoffStrategy( 1, MILLISECONDS ); + ExponentialBackoffStrategy strategy = new ExponentialBackoffStrategy( 1, MILLISECONDS ); RetryStrategy.Timeout timeout = strategy.newTimeout(); // when