diff --git a/akka-actor-tests/src/test/scala/akka/AkkaExceptionSpec.scala b/akka-actor-tests/src/test/scala/akka/AkkaExceptionSpec.scala index 210bf74f2e..f68eb81ccf 100644 --- a/akka-actor-tests/src/test/scala/akka/AkkaExceptionSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/AkkaExceptionSpec.scala @@ -1,8 +1,8 @@ -package akka; +package akka import akka.actor._ import org.scalatest.Matchers -import org.scalatest.WordSpec; +import org.scalatest.WordSpec /** * A spec that verified that the AkkaException has at least a single argument constructor of type String. diff --git a/akka-actor/src/main/scala/akka/actor/AbstractFSM.scala b/akka-actor/src/main/scala/akka/actor/AbstractFSM.scala index eb11471ab9..676e4e168f 100644 --- a/akka-actor/src/main/scala/akka/actor/AbstractFSM.scala +++ b/akka-actor/src/main/scala/akka/actor/AbstractFSM.scala @@ -195,7 +195,7 @@ abstract class AbstractFSM[S, D] extends FSM[S, D] { * @return the builder with the case statement added */ final def matchEvent[ET](eventType: Class[ET], predicate: TypedPredicate2[ET, D], apply: Apply2[ET, D, State]): FSMStateFunctionBuilder[S, D] = - new FSMStateFunctionBuilder[S, D]().event(eventType, predicate, apply); + new FSMStateFunctionBuilder[S, D]().event(eventType, predicate, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -207,7 +207,7 @@ abstract class AbstractFSM[S, D] extends FSM[S, D] { * @return the builder with the case statement added */ final def matchEvent[ET](eventType: Class[ET], apply: Apply2[ET, D, State]): FSMStateFunctionBuilder[S, D] = - new FSMStateFunctionBuilder[S, D]().event(eventType, apply); + new FSMStateFunctionBuilder[S, D]().event(eventType, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -219,7 +219,7 @@ abstract class AbstractFSM[S, D] extends FSM[S, D] { * @return the builder with the case statement added */ final def matchEvent(predicate: TypedPredicate2[AnyRef, D], apply: Apply2[AnyRef, D, State]): FSMStateFunctionBuilder[S, D] = - new FSMStateFunctionBuilder[S, D]().event(predicate, apply); + new FSMStateFunctionBuilder[S, D]().event(predicate, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -233,7 +233,7 @@ abstract class AbstractFSM[S, D] extends FSM[S, D] { * @return the builder with the case statement added */ final def matchEvent[DT <: D](eventMatches: JList[AnyRef], dataType: Class[DT], apply: Apply2[AnyRef, DT, State]): FSMStateFunctionBuilder[S, D] = - new FSMStateFunctionBuilder[S, D]().event(eventMatches, dataType, apply); + new FSMStateFunctionBuilder[S, D]().event(eventMatches, dataType, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -246,7 +246,7 @@ abstract class AbstractFSM[S, D] extends FSM[S, D] { * @return the builder with the case statement added */ final def matchEvent(eventMatches: JList[AnyRef], apply: Apply2[AnyRef, D, State]): FSMStateFunctionBuilder[S, D] = - new FSMStateFunctionBuilder[S, D]().event(eventMatches, apply); + new FSMStateFunctionBuilder[S, D]().event(eventMatches, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -259,7 +259,7 @@ abstract class AbstractFSM[S, D] extends FSM[S, D] { * @return the builder with the case statement added */ final def matchEventEquals[E, DT <: D](event: E, dataType: Class[DT], apply: Apply2[E, DT, State]): FSMStateFunctionBuilder[S, D] = - new FSMStateFunctionBuilder[S, D]().eventEquals(event, dataType, apply); + new FSMStateFunctionBuilder[S, D]().eventEquals(event, dataType, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -271,7 +271,7 @@ abstract class AbstractFSM[S, D] extends FSM[S, D] { * @return the builder with the case statement added */ final def matchEventEquals[E](event: E, apply: Apply2[E, D, State]): FSMStateFunctionBuilder[S, D] = - new FSMStateFunctionBuilder[S, D]().eventEquals(event, apply); + new FSMStateFunctionBuilder[S, D]().eventEquals(event, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. diff --git a/akka-actor/src/main/scala/akka/routing/MurmurHash.scala b/akka-actor/src/main/scala/akka/routing/MurmurHash.scala index f4fb81edb5..58aa274633 100644 --- a/akka-actor/src/main/scala/akka/routing/MurmurHash.scala +++ b/akka-actor/src/main/scala/akka/routing/MurmurHash.scala @@ -115,7 +115,7 @@ object MurmurHash { var k = hiddenMagicB var j = 0 while (j + 1 < s.length) { - val i = (s.charAt(j) << 16) + s.charAt(j + 1); + val i = (s.charAt(j) << 16) + s.charAt(j + 1) h = extendHash(h, i, c, k) c = nextMagicA(c) k = nextMagicB(k) diff --git a/akka-bench-jmh/src/main/scala/akka/remote/artery/compress/CountMinSketchBenchmark.scala b/akka-bench-jmh/src/main/scala/akka/remote/artery/compress/CountMinSketchBenchmark.scala index 088b3f3c82..f821083394 100644 --- a/akka-bench-jmh/src/main/scala/akka/remote/artery/compress/CountMinSketchBenchmark.scala +++ b/akka-bench-jmh/src/main/scala/akka/remote/artery/compress/CountMinSketchBenchmark.scala @@ -40,7 +40,7 @@ class CountMinSketchBenchmark { @Benchmark @OperationsPerInvocation(8192) def updateRandomNumbers(blackhole: Blackhole): Unit = { - var i: Int = 0; + var i: Int = 0 while (i < 8192) { blackhole.consume(countMinSketch.addObjectAndEstimateCount(preallocateIds(i), preallocateValues(i))) i += 1 diff --git a/akka-camel/src/test/scala/akka/camel/DefaultCamelTest.scala b/akka-camel/src/test/scala/akka/camel/DefaultCamelTest.scala index 4a188d9348..06de4bbbf2 100644 --- a/akka-camel/src/test/scala/akka/camel/DefaultCamelTest.scala +++ b/akka-camel/src/test/scala/akka/camel/DefaultCamelTest.scala @@ -42,7 +42,7 @@ class DefaultCamelTest extends WordSpec with SharedCamelSystem with Matchers wit } "throws exception thrown by context.stop()" in { - exception.getMessage() should ===("context"); + exception.getMessage() should ===("context") } "tries to stop both template and context" in { diff --git a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala index d808e1e838..a9104a935b 100644 --- a/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala +++ b/akka-multi-node-testkit/src/main/scala/akka/remote/testconductor/Player.scala @@ -99,7 +99,7 @@ trait Player { this: TestConductorExt ⇒ val barrierTimeout = stop.timeLeft if (barrierTimeout < Duration.Zero) { client ! ToServer(FailBarrier(b)) - throw new TimeoutException("Server timed out while waiting for barrier " + b); + throw new TimeoutException("Server timed out while waiting for barrier " + b) } try { implicit val timeout = Timeout(barrierTimeout + Settings.QueryTimeout.duration) diff --git a/akka-osgi/src/test/scala/akka/osgi/test/TestActivators.scala b/akka-osgi/src/test/scala/akka/osgi/test/TestActivators.scala index d7f13e12f4..57536ef0d7 100644 --- a/akka-osgi/src/test/scala/akka/osgi/test/TestActivators.scala +++ b/akka-osgi/src/test/scala/akka/osgi/test/TestActivators.scala @@ -34,7 +34,7 @@ class PingPongActorSystemActivator extends ActorSystemActivator { */ class RuntimeNameActorSystemActivator extends ActorSystemActivator { - def configure(context: BundleContext, system: ActorSystem) = registerService(context, system); + def configure(context: BundleContext, system: ActorSystem) = registerService(context, system) override def getActorSystemName(context: BundleContext) = TestActivators.ACTOR_SYSTEM_NAME_PATTERN.format(context.getBundle.getBundleId) diff --git a/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSMBase.scala b/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSMBase.scala index 6cf043dcd1..746a2c417d 100644 --- a/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSMBase.scala +++ b/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSMBase.scala @@ -801,7 +801,7 @@ abstract class AbstractPersistentFSMBase[S, D, E] extends PersistentFSMBase[S, D * @return the builder with the case statement added */ final def matchEvent[ET](eventType: Class[ET], predicate: TypedPredicate2[ET, D], apply: Apply2[ET, D, State]): FSMStateFunctionBuilder[S, D, E] = - new FSMStateFunctionBuilder[S, D, E]().event(eventType, predicate, apply); + new FSMStateFunctionBuilder[S, D, E]().event(eventType, predicate, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -813,7 +813,7 @@ abstract class AbstractPersistentFSMBase[S, D, E] extends PersistentFSMBase[S, D * @return the builder with the case statement added */ final def matchEvent[ET](eventType: Class[ET], apply: Apply2[ET, D, State]): FSMStateFunctionBuilder[S, D, E] = - new FSMStateFunctionBuilder[S, D, E]().event(eventType, apply); + new FSMStateFunctionBuilder[S, D, E]().event(eventType, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -825,7 +825,7 @@ abstract class AbstractPersistentFSMBase[S, D, E] extends PersistentFSMBase[S, D * @return the builder with the case statement added */ final def matchEvent(predicate: TypedPredicate2[AnyRef, D], apply: Apply2[AnyRef, D, State]): FSMStateFunctionBuilder[S, D, E] = - new FSMStateFunctionBuilder[S, D, E]().event(predicate, apply); + new FSMStateFunctionBuilder[S, D, E]().event(predicate, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -839,7 +839,7 @@ abstract class AbstractPersistentFSMBase[S, D, E] extends PersistentFSMBase[S, D * @return the builder with the case statement added */ final def matchEvent[DT <: D](eventMatches: JList[AnyRef], dataType: Class[DT], apply: Apply2[AnyRef, DT, State]): FSMStateFunctionBuilder[S, D, E] = - new FSMStateFunctionBuilder[S, D, E]().event(eventMatches, dataType, apply); + new FSMStateFunctionBuilder[S, D, E]().event(eventMatches, dataType, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -852,7 +852,7 @@ abstract class AbstractPersistentFSMBase[S, D, E] extends PersistentFSMBase[S, D * @return the builder with the case statement added */ final def matchEvent(eventMatches: JList[AnyRef], apply: Apply2[AnyRef, D, State]): FSMStateFunctionBuilder[S, D, E] = - new FSMStateFunctionBuilder[S, D, E]().event(eventMatches, apply); + new FSMStateFunctionBuilder[S, D, E]().event(eventMatches, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -865,7 +865,7 @@ abstract class AbstractPersistentFSMBase[S, D, E] extends PersistentFSMBase[S, D * @return the builder with the case statement added */ final def matchEventEquals[Ev, DT <: D](event: Ev, dataType: Class[DT], apply: Apply2[Ev, DT, State]): FSMStateFunctionBuilder[S, D, E] = - new FSMStateFunctionBuilder[S, D, E]().eventEquals(event, dataType, apply); + new FSMStateFunctionBuilder[S, D, E]().eventEquals(event, dataType, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. @@ -877,7 +877,7 @@ abstract class AbstractPersistentFSMBase[S, D, E] extends PersistentFSMBase[S, D * @return the builder with the case statement added */ final def matchEventEquals[Ev](event: Ev, apply: Apply2[Ev, D, State]): FSMStateFunctionBuilder[S, D, E] = - new FSMStateFunctionBuilder[S, D, E]().eventEquals(event, apply); + new FSMStateFunctionBuilder[S, D, E]().eventEquals(event, apply) /** * Create an [[akka.japi.pf.FSMStateFunctionBuilder]] with the first case statement set. diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/BenchmarkFileReporter.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/BenchmarkFileReporter.scala index f39d9f08f3..71c21a2344 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/BenchmarkFileReporter.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/BenchmarkFileReporter.scala @@ -41,7 +41,7 @@ object BenchmarkFileReporter { Try("git describe".!!.trim).getOrElse("[unknown]") } val testResultFile: File = { - val timestamp = formatter.format(LocalDateTime.ofInstant(Instant.now(), ZoneId.systemDefault())); + val timestamp = formatter.format(LocalDateTime.ofInstant(Instant.now(), ZoneId.systemDefault())) val fileName = s"$timestamp-Artery-$testName-$gitCommit-results.txt" new File(targetDirectory, fileName) } diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/aeron/AeronStreamMaxThroughputSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/aeron/AeronStreamMaxThroughputSpec.scala index 40c447d5dd..265dc7dbd7 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/aeron/AeronStreamMaxThroughputSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/artery/aeron/AeronStreamMaxThroughputSpec.scala @@ -86,7 +86,7 @@ abstract class AeronStreamMaxThroughputSpec val pool = new EnvelopeBufferPool(1024 * 1024, 128) - val cncByteBuffer = IoUtil.mapExistingFile(new File(driver.aeronDirectoryName, CncFileDescriptor.CNC_FILE), "cnc"); + val cncByteBuffer = IoUtil.mapExistingFile(new File(driver.aeronDirectoryName, CncFileDescriptor.CNC_FILE), "cnc") val stats = new AeronStat(AeronStat.mapCounters(cncByteBuffer)) diff --git a/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala b/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala index 8a28e4b48b..4420ef2c31 100644 --- a/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala @@ -187,7 +187,7 @@ class RemotingSpec extends AkkaSpec(RemotingSpec.cfg) with ImplicitSender with D } override def atStartup() = { - muteSystem(system); + muteSystem(system) remoteSystem.eventStream.publish(TestEvent.Mute( EventFilter[EndpointException](), EventFilter.error(start = "AssociationError"), diff --git a/akka-stream-testkit/src/main/scala/akka/stream/testkit/scaladsl/TestSource.scala b/akka-stream-testkit/src/main/scala/akka/stream/testkit/scaladsl/TestSource.scala index ad1bea1d19..b9c7630b02 100644 --- a/akka-stream-testkit/src/main/scala/akka/stream/testkit/scaladsl/TestSource.scala +++ b/akka-stream-testkit/src/main/scala/akka/stream/testkit/scaladsl/TestSource.scala @@ -8,7 +8,7 @@ import akka.stream.Attributes.none import akka.stream.scaladsl._ import akka.stream.testkit._ -import akka.actor.ActorSystem; +import akka.actor.ActorSystem /** * Factory methods for test sources. diff --git a/akka-stream-tests/src/test/scala/akka/stream/impl/TimeoutsSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/impl/TimeoutsSpec.scala index 0362ebbefa..a808054356 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/impl/TimeoutsSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/impl/TimeoutsSpec.scala @@ -290,9 +290,9 @@ class TimeoutsSpec extends StreamSpec { RunnableGraph.fromGraph(GraphDSL.create() { implicit b ⇒ import GraphDSL.Implicits._ val timeoutStage = b.add(BidiFlow.bidirectionalIdleTimeout[String, Int](2.seconds)) - Source.fromPublisher(upWrite) ~> timeoutStage.in1; + Source.fromPublisher(upWrite) ~> timeoutStage.in1 timeoutStage.out1 ~> Sink.fromSubscriber(downRead) - Sink.fromSubscriber(upRead) <~ timeoutStage.out2; + Sink.fromSubscriber(upRead) <~ timeoutStage.out2 timeoutStage.in2 <~ Source.fromPublisher(downWrite) ClosedShape }).run() @@ -338,9 +338,9 @@ class TimeoutsSpec extends StreamSpec { RunnableGraph.fromGraph(GraphDSL.create() { implicit b ⇒ import GraphDSL.Implicits._ val timeoutStage = b.add(BidiFlow.bidirectionalIdleTimeout[String, Int](2.seconds)) - Source.fromPublisher(upWrite) ~> timeoutStage.in1; + Source.fromPublisher(upWrite) ~> timeoutStage.in1 timeoutStage.out1 ~> Sink.fromSubscriber(downRead) - Sink.fromSubscriber(upRead) <~ timeoutStage.out2; + Sink.fromSubscriber(upRead) <~ timeoutStage.out2 timeoutStage.in2 <~ Source.fromPublisher(downWrite) ClosedShape }).run()