diff --git a/akka-actor-tests/src/test/java/akka/actor/ActorCreationTest.java b/akka-actor-tests/src/test/java/akka/actor/ActorCreationTest.java index 8f501de0e3..08b54483c5 100644 --- a/akka-actor-tests/src/test/java/akka/actor/ActorCreationTest.java +++ b/akka-actor-tests/src/test/java/akka/actor/ActorCreationTest.java @@ -8,8 +8,9 @@ import static org.junit.Assert.*; import org.junit.Test; import akka.japi.Creator; +import org.scalatest.junit.JUnitSuite; -public class ActorCreationTest { +public class ActorCreationTest extends JUnitSuite { @Test public void testWrongCreator() { diff --git a/akka-actor-tests/src/test/java/akka/actor/InboxJavaAPITest.java b/akka-actor-tests/src/test/java/akka/actor/InboxJavaAPITest.java index 4b3ae52bfa..e40e92dd9e 100644 --- a/akka-actor-tests/src/test/java/akka/actor/InboxJavaAPITest.java +++ b/akka-actor-tests/src/test/java/akka/actor/InboxJavaAPITest.java @@ -10,9 +10,10 @@ import org.junit.ClassRule; import org.junit.Test; import akka.testkit.AkkaJUnitActorSystemResource; import akka.testkit.AkkaSpec; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.duration.FiniteDuration; -public class InboxJavaAPITest { +public class InboxJavaAPITest extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = new AkkaJUnitActorSystemResource("InboxJavaAPITest", diff --git a/akka-actor-tests/src/test/java/akka/actor/JavaAPI.java b/akka-actor-tests/src/test/java/akka/actor/JavaAPI.java index f242bcfee9..804f6eeed1 100644 --- a/akka-actor-tests/src/test/java/akka/actor/JavaAPI.java +++ b/akka-actor-tests/src/test/java/akka/actor/JavaAPI.java @@ -20,13 +20,14 @@ import akka.testkit.TestProbe; import org.junit.ClassRule; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.Option; import java.util.Optional; import static org.junit.Assert.*; -public class JavaAPI { +public class JavaAPI extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = new AkkaJUnitActorSystemResource("JavaAPI", diff --git a/akka-actor-tests/src/test/java/akka/actor/JavaExtension.java b/akka-actor-tests/src/test/java/akka/actor/JavaExtension.java index 91337a03d7..0b270df0ad 100644 --- a/akka-actor-tests/src/test/java/akka/actor/JavaExtension.java +++ b/akka-actor-tests/src/test/java/akka/actor/JavaExtension.java @@ -7,10 +7,11 @@ import akka.testkit.AkkaJUnitActorSystemResource; import org.junit.*; import akka.testkit.AkkaSpec; import com.typesafe.config.ConfigFactory; +import org.scalatest.junit.JUnitSuite; import static org.junit.Assert.*; -public class JavaExtension { +public class JavaExtension extends JUnitSuite { static class TestExtensionId extends AbstractExtensionId implements ExtensionIdProvider { public final static TestExtensionId TestExtensionProvider = new TestExtensionId(); diff --git a/akka-actor-tests/src/test/java/akka/actor/StashJavaAPI.java b/akka-actor-tests/src/test/java/akka/actor/StashJavaAPI.java index 3487ead16c..095ccc1b0d 100644 --- a/akka-actor-tests/src/test/java/akka/actor/StashJavaAPI.java +++ b/akka-actor-tests/src/test/java/akka/actor/StashJavaAPI.java @@ -5,8 +5,9 @@ import akka.testkit.TestProbe; import org.junit.ClassRule; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; -public class StashJavaAPI { +public class StashJavaAPI extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = diff --git a/akka-actor-tests/src/test/java/akka/dispatch/JavaFutureTests.java b/akka-actor-tests/src/test/java/akka/dispatch/JavaFutureTests.java index 1530543dc8..421cd488fb 100644 --- a/akka-actor-tests/src/test/java/akka/dispatch/JavaFutureTests.java +++ b/akka-actor-tests/src/test/java/akka/dispatch/JavaFutureTests.java @@ -5,6 +5,7 @@ import akka.actor.ActorSystem; import akka.japi.*; import org.junit.ClassRule; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.Await; import scala.concurrent.Future; import scala.concurrent.Promise; @@ -22,7 +23,7 @@ import static akka.japi.Util.classTag; import akka.testkit.AkkaSpec; -public class JavaFutureTests { +public class JavaFutureTests extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = diff --git a/akka-actor-tests/src/test/java/akka/event/LoggingAdapterTest.java b/akka-actor-tests/src/test/java/akka/event/LoggingAdapterTest.java index 1c0589976f..0af4fca970 100644 --- a/akka-actor-tests/src/test/java/akka/event/LoggingAdapterTest.java +++ b/akka-actor-tests/src/test/java/akka/event/LoggingAdapterTest.java @@ -11,7 +11,9 @@ import static akka.event.Logging.*; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.duration.Duration; +import scala.util.control.NoStackTrace; import java.util.*; import java.util.concurrent.TimeUnit; @@ -21,7 +23,7 @@ import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertSame; -public class LoggingAdapterTest { +public class LoggingAdapterTest extends JUnitSuite { private static final Config config = ConfigFactory.parseString( "akka.loglevel = DEBUG\n" + @@ -37,7 +39,12 @@ public class LoggingAdapterTest { log.error("One arg message: {}", "the arg"); expectLog(ErrorLevel(), "One arg message: the arg"); - Throwable cause = new IllegalStateException("This state is illegal"); + Throwable cause = new IllegalStateException("This state is illegal") { + @Override + public synchronized Throwable fillInStackTrace() { + return this; // no stack trace + } + }; log.error(cause, "Two args message: {}, {}", "an arg", "another arg"); expectLog(ErrorLevel(), "Two args message: an arg, another arg", cause); diff --git a/akka-actor-tests/src/test/java/akka/japi/JavaAPITestBase.java b/akka-actor-tests/src/test/java/akka/japi/JavaAPITestBase.java index 39d42f68de..10c40159f8 100644 --- a/akka-actor-tests/src/test/java/akka/japi/JavaAPITestBase.java +++ b/akka-actor-tests/src/test/java/akka/japi/JavaAPITestBase.java @@ -5,11 +5,13 @@ import akka.event.LoggingAdapter; import akka.event.NoLogging; import akka.serialization.JavaSerializer; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; + import java.util.concurrent.Callable; import static org.junit.Assert.*; -public class JavaAPITestBase { +public class JavaAPITestBase extends JUnitSuite { @Test public void shouldCreateSomeString() { diff --git a/akka-actor-tests/src/test/java/akka/japi/MatchBuilderTest.java b/akka-actor-tests/src/test/java/akka/japi/MatchBuilderTest.java index c643f7ad34..f0b1ff443d 100644 --- a/akka-actor-tests/src/test/java/akka/japi/MatchBuilderTest.java +++ b/akka-actor-tests/src/test/java/akka/japi/MatchBuilderTest.java @@ -9,11 +9,12 @@ import akka.japi.pf.Match; import org.junit.Rule; import org.junit.rules.ExpectedException; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.MatchError; import static org.junit.Assert.*; -public class MatchBuilderTest { +public class MatchBuilderTest extends JUnitSuite { @Rule public ExpectedException exception = ExpectedException.none(); diff --git a/akka-actor-tests/src/test/java/akka/japi/pf/PFBuilderTest.java b/akka-actor-tests/src/test/java/akka/japi/pf/PFBuilderTest.java index 69fa172494..203125448f 100644 --- a/akka-actor-tests/src/test/java/akka/japi/pf/PFBuilderTest.java +++ b/akka-actor-tests/src/test/java/akka/japi/pf/PFBuilderTest.java @@ -5,11 +5,13 @@ package akka.japi.pf; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.PartialFunction; import static org.junit.Assert.*; -public class PFBuilderTest { +public class PFBuilderTest extends JUnitSuite { + @Test public void pfbuilder_matchAny_should_infer_declared_input_type_for_lambda() { PartialFunction pf = new PFBuilder() diff --git a/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java b/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java index 5cdf506646..52318630ab 100644 --- a/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java +++ b/akka-actor-tests/src/test/java/akka/pattern/PatternsTest.java @@ -7,6 +7,7 @@ import akka.testkit.AkkaSpec; import akka.testkit.TestProbe; import org.junit.ClassRule; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.Await; import scala.concurrent.duration.Duration; @@ -17,7 +18,7 @@ import static org.junit.Assert.assertEquals; /** * Copyright (C) 2009-2016 Lightbend Inc. */ -public class PatternsTest { +public class PatternsTest extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = new AkkaJUnitActorSystemResource("JavaAPI", diff --git a/akka-actor-tests/src/test/java/akka/util/ByteStringTest.java b/akka-actor-tests/src/test/java/akka/util/ByteStringTest.java index f356a365b3..35de46524a 100644 --- a/akka-actor-tests/src/test/java/akka/util/ByteStringTest.java +++ b/akka-actor-tests/src/test/java/akka/util/ByteStringTest.java @@ -4,11 +4,13 @@ package akka.util; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; +import org.scalatest.junit.JUnitSuiteLike; import scala.concurrent.duration.Duration; import static junit.framework.TestCase.assertEquals; -public class ByteStringTest { +public class ByteStringTest extends JUnitSuite { @Test public void testCreation() { @@ -20,6 +22,7 @@ public class ByteStringTest { public void testBuilderCreation() { final ByteStringBuilder sb = ByteString.createBuilder(); sb.append(ByteString.fromString("Hello")); + sb.append(ByteString.fromString(" ")); sb.append(ByteString.fromString("World")); assertEquals(ByteString.fromString("Hello World"), sb.result()); } diff --git a/akka-actor-tests/src/test/java/akka/util/JavaDuration.java b/akka-actor-tests/src/test/java/akka/util/JavaDuration.java index 1fd3e2041b..ec3bec9c79 100644 --- a/akka-actor-tests/src/test/java/akka/util/JavaDuration.java +++ b/akka-actor-tests/src/test/java/akka/util/JavaDuration.java @@ -4,9 +4,10 @@ package akka.util; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.duration.Duration; -public class JavaDuration { +public class JavaDuration extends JUnitSuite { @Test public void testCreation() { diff --git a/akka-camel/src/test/java/akka/camel/ConsumerJavaTest.java b/akka-camel/src/test/java/akka/camel/ConsumerJavaTest.java index c6aef38a6b..fb16c0fedb 100644 --- a/akka-camel/src/test/java/akka/camel/ConsumerJavaTest.java +++ b/akka-camel/src/test/java/akka/camel/ConsumerJavaTest.java @@ -7,6 +7,7 @@ package akka.camel; import akka.testkit.AkkaJUnitActorSystemResource; import akka.testkit.AkkaSpec; import org.junit.ClassRule; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.duration.Duration; import scala.concurrent.duration.FiniteDuration; import akka.actor.ActorSystem; @@ -19,7 +20,7 @@ import org.junit.Test; import java.util.concurrent.TimeUnit; import static org.junit.Assert.*; -public class ConsumerJavaTest { +public class ConsumerJavaTest extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = diff --git a/akka-camel/src/test/java/akka/camel/CustomRouteTest.java b/akka-camel/src/test/java/akka/camel/CustomRouteTest.java index e941772799..eeb090b6cb 100644 --- a/akka-camel/src/test/java/akka/camel/CustomRouteTest.java +++ b/akka-camel/src/test/java/akka/camel/CustomRouteTest.java @@ -7,6 +7,7 @@ import akka.camel.javaapi.UntypedProducerActor; import akka.testkit.AkkaJUnitActorSystemResource; import akka.util.Timeout; import org.junit.*; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.Await; import scala.concurrent.ExecutionContext; import scala.concurrent.duration.Duration; @@ -19,7 +20,7 @@ import org.apache.camel.component.mock.MockEndpoint; import java.util.concurrent.TimeUnit; -public class CustomRouteTest { +public class CustomRouteTest extends JUnitSuite { @Rule public AkkaJUnitActorSystemResource actorSystemResource = diff --git a/akka-camel/src/test/java/akka/camel/MessageJavaTest.java b/akka-camel/src/test/java/akka/camel/MessageJavaTest.java index 701e7ab5fb..d3b06ddb53 100644 --- a/akka-camel/src/test/java/akka/camel/MessageJavaTest.java +++ b/akka-camel/src/test/java/akka/camel/MessageJavaTest.java @@ -11,6 +11,7 @@ import org.apache.camel.NoTypeConversionAvailableException; import org.apache.camel.converter.stream.InputStreamCache; import org.junit.ClassRule; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import java.io.InputStream; import java.util.*; @@ -20,7 +21,7 @@ import static org.junit.Assert.assertEquals; /** * */ -public class MessageJavaTest { +public class MessageJavaTest extends JUnitSuite { private Map empty = new HashMap(); @ClassRule diff --git a/akka-cluster-tools/src/test/java/akka/cluster/client/ClusterClientTest.java b/akka-cluster-tools/src/test/java/akka/cluster/client/ClusterClientTest.java index bbee5a2063..306593c979 100644 --- a/akka-cluster-tools/src/test/java/akka/cluster/client/ClusterClientTest.java +++ b/akka-cluster-tools/src/test/java/akka/cluster/client/ClusterClientTest.java @@ -18,8 +18,9 @@ import akka.actor.ActorSystem; import akka.actor.Props; import akka.actor.UntypedActor; import akka.testkit.AkkaJUnitActorSystemResource; +import org.scalatest.junit.JUnitSuite; -public class ClusterClientTest { +public class ClusterClientTest extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = diff --git a/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java b/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java index 193e743a8a..c1c9311bd6 100644 --- a/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java +++ b/akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java @@ -17,8 +17,9 @@ import akka.actor.Props; import akka.actor.UntypedActor; import akka.event.Logging; import akka.event.LoggingAdapter; +import org.scalatest.junit.JUnitSuite; -public class DistributedPubSubMediatorTest { +public class DistributedPubSubMediatorTest extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = diff --git a/akka-contrib/src/test/java/akka/contrib/pattern/ReliableProxyTest.java b/akka-contrib/src/test/java/akka/contrib/pattern/ReliableProxyTest.java index 23404e713d..376ac11072 100644 --- a/akka-contrib/src/test/java/akka/contrib/pattern/ReliableProxyTest.java +++ b/akka-contrib/src/test/java/akka/contrib/pattern/ReliableProxyTest.java @@ -12,6 +12,7 @@ import akka.testkit.AkkaJUnitActorSystemResource; import org.junit.ClassRule; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.duration.Duration; import akka.testkit.TestProbe; @@ -21,7 +22,7 @@ import akka.contrib.pattern.ReliableProxy; //#import -public class ReliableProxyTest { +public class ReliableProxyTest extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = diff --git a/akka-contrib/src/test/java/akka/contrib/throttle/TimerBasedThrottlerTest.java b/akka-contrib/src/test/java/akka/contrib/throttle/TimerBasedThrottlerTest.java index af58b8e745..1950144c56 100644 --- a/akka-contrib/src/test/java/akka/contrib/throttle/TimerBasedThrottlerTest.java +++ b/akka-contrib/src/test/java/akka/contrib/throttle/TimerBasedThrottlerTest.java @@ -8,6 +8,8 @@ import org.junit.ClassRule; import org.junit.Test; import java.util.concurrent.TimeUnit; + +import org.scalatest.junit.JUnitSuite; import scala.concurrent.duration.Duration; import com.typesafe.config.ConfigFactory; import akka.actor.ActorRef; @@ -17,7 +19,7 @@ import akka.actor.UntypedActor; import akka.contrib.throttle.TimerBasedThrottler; import akka.testkit.AkkaJUnitActorSystemResource; -public class TimerBasedThrottlerTest { +public class TimerBasedThrottlerTest extends JUnitSuite { @ClassRule public static AkkaJUnitActorSystemResource actorSystemResource = new AkkaJUnitActorSystemResource( diff --git a/akka-docs/rst/scala/code/docs/stream/QuickStartDocSpec.scala b/akka-docs/rst/scala/code/docs/stream/QuickStartDocSpec.scala index a641b41cb4..7a47f0c8a0 100644 --- a/akka-docs/rst/scala/code/docs/stream/QuickStartDocSpec.scala +++ b/akka-docs/rst/scala/code/docs/stream/QuickStartDocSpec.scala @@ -29,6 +29,8 @@ class QuickStartDocSpec extends WordSpec with BeforeAndAfterAll with ScalaFuture system.terminate() } + def println(any: Any) = () // silence printing stuff + "demonstrate Source" in { //#create-source val source: Source[Int, NotUsed] = Source(1 to 100) diff --git a/akka-persistence/src/test/java/akka/persistence/fsm/AbstractPersistentFSMTest.java b/akka-persistence/src/test/java/akka/persistence/fsm/AbstractPersistentFSMTest.java index 990907a354..aa83e528ff 100644 --- a/akka-persistence/src/test/java/akka/persistence/fsm/AbstractPersistentFSMTest.java +++ b/akka-persistence/src/test/java/akka/persistence/fsm/AbstractPersistentFSMTest.java @@ -21,6 +21,7 @@ import java.util.concurrent.TimeUnit; import akka.persistence.fsm.PersistentFSM.CurrentState; import org.junit.Test; +import org.scalatest.junit.JUnitSuite; import scala.concurrent.duration.Duration; import static akka.persistence.fsm.AbstractPersistentFSMTest.WebStoreCustomerFSM.UserState; @@ -40,7 +41,7 @@ import static org.junit.Assert.assertThat; import static org.junit.Assert.assertTrue; import static org.junit.matchers.JUnitMatchers.hasItems; -public class AbstractPersistentFSMTest { +public class AbstractPersistentFSMTest extends JUnitSuite { private static Option none = Option.none(); @ClassRule 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 3b7b6b20a5..b0f19d844b 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 @@ -9,7 +9,7 @@ import akka.Done import akka.stream.scaladsl._ import akka.stream.testkit.Utils._ import akka.stream.testkit.{ TestPublisher, TestSubscriber } -import akka.stream.{ ActorMaterializer, ClosedShape } +import akka.stream._ import scala.concurrent.duration._ import scala.concurrent.{ Await, Future } import akka.testkit.AkkaSpec