make most AkkaSpec-based tests runnable in Eclipse

This commit is contained in:
Roland 2011-10-21 17:01:22 +02:00
parent d55f02e6c1
commit bb942750aa
50 changed files with 51 additions and 2 deletions

View file

@ -51,6 +51,7 @@ object ActorFireForgetRequestReplySpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ActorFireForgetRequestReplySpec extends AkkaSpec with BeforeAndAfterEach {
import ActorFireForgetRequestReplySpec._

View file

@ -16,6 +16,7 @@ object ActorLifeCycleSpec {
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ActorLifeCycleSpec extends AkkaSpec with BeforeAndAfterEach with ImplicitSender {
import ActorLifeCycleSpec._

View file

@ -113,6 +113,7 @@ object ActorRefSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ActorRefSpec extends AkkaSpec {
import akka.actor.ActorRefSpec._

View file

@ -8,6 +8,7 @@ import akka.dispatch.FutureTimeoutException
import akka.util.duration._
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ActorTimeoutSpec extends AkkaSpec with BeforeAndAfterAll {
def actorWithTimeout(t: Timeout): ActorRef = actorOf(Props(creator = () new Actor {

View file

@ -8,6 +8,7 @@ import akka.dispatch._
import akka.testkit.TestActorRef
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ChannelSpec extends AkkaSpec {
"A Channel" must {

View file

@ -2,6 +2,7 @@ package akka.actor
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ClusterSpec extends AkkaSpec {
"ClusterSpec: A Deployer" must {

View file

@ -9,6 +9,7 @@ import akka.testkit._
import akka.util.duration._
import java.util.concurrent.atomic._
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class DeathWatchSpec extends AkkaSpec with BeforeAndAfterEach with ImplicitSender {
"The Death Watch" must {

View file

@ -8,6 +8,7 @@ import akka.testkit.AkkaSpec
import akka.util.duration._
import DeploymentConfig._
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class DeployerSpec extends AkkaSpec {
"A Deployer" must {

View file

@ -99,6 +99,7 @@ object FSMActorSpec {
case class CodeState(soFar: String, code: String)
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class FSMActorSpec extends AkkaSpec(Configuration("akka.actor.debug.fsm" -> true)) with ImplicitSender {
import FSMActorSpec._

View file

@ -8,6 +8,7 @@ import akka.testkit.{ AkkaSpec, ImplicitSender }
import akka.util.Duration
import akka.util.duration._
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class FSMTimingSpec extends AkkaSpec with ImplicitSender {
import FSMTimingSpec._
import FSM._

View file

@ -35,6 +35,7 @@ object FSMTransitionSpec {
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class FSMTransitionSpec extends AkkaSpec with ImplicitSender {
import FSMTransitionSpec._

View file

@ -27,6 +27,7 @@ object ForwardActorSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ForwardActorSpec extends AkkaSpec {
import ForwardActorSpec._

View file

@ -6,6 +6,7 @@ package akka.actor
import akka.testkit._
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class HotSwapSpec extends AkkaSpec {
"An Actor" must {

View file

@ -170,6 +170,7 @@ object IOActorSpec {
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class IOActorSpec extends AkkaSpec with BeforeAndAfterEach {
import IOActorSpec._

View file

@ -19,6 +19,7 @@ object LocalActorRefProviderSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class LocalActorRefProviderSpec extends AkkaSpec {
import akka.actor.LocalActorRefProviderSpec._

View file

@ -9,6 +9,7 @@ import akka.util.duration._
import java.util.concurrent.atomic.AtomicInteger
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ReceiveTimeoutSpec extends AkkaSpec {
"An actor with receive timeout" must {

View file

@ -12,6 +12,7 @@ import java.util.concurrent.{ TimeUnit, CountDownLatch }
import org.multiverse.api.latches.StandardLatch
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class RestartStrategySpec extends AkkaSpec {
override def atStartup() {

View file

@ -7,6 +7,7 @@ import org.multiverse.api.latches.StandardLatch
import java.util.concurrent.{ ScheduledFuture, ConcurrentLinkedQueue, CountDownLatch, TimeUnit }
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class SchedulerSpec extends AkkaSpec with BeforeAndAfterEach {
private val futures = new ConcurrentLinkedQueue[ScheduledFuture[AnyRef]]()

View file

@ -21,6 +21,7 @@ object SupervisorHierarchySpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class SupervisorHierarchySpec extends AkkaSpec {
import SupervisorHierarchySpec._

View file

@ -8,6 +8,7 @@ import akka.dispatch.{ PinnedDispatcher, Dispatchers }
import java.util.concurrent.{ TimeUnit, CountDownLatch }
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class SupervisorMiscSpec extends AkkaSpec {
"A Supervisor" must {

View file

@ -13,6 +13,7 @@ import akka.testkit.{ TestKit, EventFilter, filterEvents, filterException }
import akka.testkit.AkkaSpec
import akka.testkit.ImplicitSender
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class SupervisorTreeSpec extends AkkaSpec with ImplicitSender {
"In a 3 levels deep supervisor tree (linked in the constructor) we" must {

View file

@ -10,6 +10,7 @@ import akka.testkit.{ TestKit, filterEvents, EventFilter }
import akka.testkit.AkkaSpec
import akka.testkit.ImplicitSender
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class Ticket669Spec extends AkkaSpec with BeforeAndAfterAll with ImplicitSender {
import Ticket669Spec._

View file

@ -136,6 +136,7 @@ object TypedActorSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class TypedActorSpec extends AkkaSpec with BeforeAndAfterEach with BeforeAndAfterAll {
import TypedActorSpec._

View file

@ -440,6 +440,7 @@ abstract class ActorModelSpec extends AkkaSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class DispatcherModelSpec extends ActorModelSpec {
import ActorModelSpec._
@ -469,6 +470,7 @@ class DispatcherModelSpec extends ActorModelSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class BalancingDispatcherModelSpec extends ActorModelSpec {
import ActorModelSpec._

View file

@ -5,6 +5,7 @@ import akka.dispatch.{ Mailbox, Dispatchers }
import akka.actor.{ LocalActorRef, IllegalActorStateException, Actor, Props }
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class BalancingDispatcherSpec extends AkkaSpec {
def newWorkStealer() = app.dispatcherFactory.newBalancingDispatcher("pooled-dispatcher", 1).build

View file

@ -24,6 +24,7 @@ object DispatcherActorSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class DispatcherActorSpec extends AkkaSpec {
import DispatcherActorSpec._

View file

@ -9,6 +9,7 @@ import akka.testkit.AkkaSpec
*
* @author Jan Van Besien
*/
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class DispatcherActorsSpec extends AkkaSpec {
class SlowActor(finishedCounter: CountDownLatch) extends Actor {

View file

@ -9,6 +9,7 @@ import akka.dispatch._
import akka.testkit.AkkaSpec
import akka.config.Configuration
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class DispatchersSpec extends AkkaSpec {
import app.dispatcherFactory._

View file

@ -18,6 +18,7 @@ object PinnedActorSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class PinnedActorSpec extends AkkaSpec with BeforeAndAfterEach {
import PinnedActorSpec._

View file

@ -6,6 +6,7 @@ import akka.actor.Actor._
import akka.routing._
import java.util.concurrent.atomic.AtomicInteger
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ListenerSpec extends AkkaSpec {
"Listener" must {

View file

@ -7,6 +7,7 @@ package akka.config
import akka.testkit.AkkaSpec
import akka.AkkaApplication
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ConfigSpec extends AkkaSpec(AkkaApplication("ConfigSpec", Configuration.fromFile("config/akka-reference.conf"))) {
"The default configuration file (i.e. akka-reference.conf)" must {

View file

@ -36,6 +36,7 @@ object FutureSpec {
class JavaFutureSpec extends JavaFutureTests with JUnitSuite
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class FutureSpec extends AkkaSpec with Checkers with BeforeAndAfterAll {
import FutureSpec._

View file

@ -11,7 +11,7 @@ import akka.util.Duration._
import akka.actor.{ LocalActorRef, Actor, NullChannel }
import akka.testkit.AkkaSpec
@RunWith(classOf[JUnitRunner])
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
abstract class MailboxSpec extends AkkaSpec with BeforeAndAfterAll with BeforeAndAfterEach {
def name: String

View file

@ -3,6 +3,7 @@ package akka.dispatch
import akka.actor.{ Props, LocalActorRef, Actor }
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class PriorityDispatcherSpec extends AkkaSpec {
"A PriorityDispatcher" must {

View file

@ -6,6 +6,7 @@ import akka.actor.Timeout
import akka.util.duration._
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class PromiseStreamSpec extends AkkaSpec {
"A PromiseStream" must {

View file

@ -20,6 +20,7 @@ object EventBusSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
abstract class EventBusSpec(busName: String) extends AkkaSpec with BeforeAndAfterEach {
import EventBusSpec._
type BusType <: EventBus

View file

@ -25,6 +25,7 @@ object ActorPoolSpec {
val faultHandler = OneForOneStrategy(List(classOf[Exception]), 5, 1000)
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ActorPoolSpec extends AkkaSpec {
import ActorPoolSpec._

View file

@ -8,6 +8,7 @@ import akka.testkit.AkkaSpec
import akka.actor.DeploymentConfig._
import akka.routing.Routing.Broadcast
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ConfiguredLocalRoutingSpec extends AkkaSpec {
"round robin router" must {

View file

@ -19,6 +19,7 @@ object RoutingSpec {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class RoutingSpec extends AkkaSpec {
import akka.routing.RoutingSpec._

View file

@ -17,6 +17,7 @@ object SerializeSpec {
case class Record(id: Int, person: Person)
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class SerializeSpec extends AkkaSpec {
import SerializeSpec._

View file

@ -4,6 +4,7 @@ import akka.actor._
import akka.routing._
import akka.testkit.AkkaSpec
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class Ticket703Spec extends AkkaSpec {
"A ? call to an actor pool" should {

View file

@ -9,7 +9,7 @@ import akka.testkit.AkkaSpec
import org.junit.runner.RunWith
import org.scalatest.junit.JUnitRunner
@RunWith(classOf[JUnitRunner])
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ConfigSpec extends AkkaSpec {
"The default configuration file (i.e. akka-reference.conf)" should {

View file

@ -9,6 +9,7 @@ import akka.serialization.SerializeSpec.Person
case class MyMessage(id: Long, name: String, status: Boolean)
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ActorSerializeSpec extends AkkaSpec with BeforeAndAfterAll {
lazy val remote: Remote = {

View file

@ -53,6 +53,7 @@ object CoordinatedIncrement {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class CoordinatedIncrementSpec extends AkkaSpec with BeforeAndAfterAll {
import CoordinatedIncrement._

View file

@ -98,6 +98,7 @@ object FickleFriends {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class FickleFriendsSpec extends AkkaSpec with BeforeAndAfterAll {
import FickleFriends._

View file

@ -75,6 +75,7 @@ object SimpleTransactor {
}
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class TransactorSpec extends AkkaSpec {
import TransactorIncrement._
import SimpleTransactor._

View file

@ -90,6 +90,7 @@ object TestActorRefSpec {
}
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class TestActorRefSpec extends AkkaSpec with BeforeAndAfterEach {
import TestActorRefSpec._

View file

@ -9,6 +9,7 @@ import org.scalatest.{ BeforeAndAfterEach, WordSpec }
import akka.actor._
import akka.util.duration._
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class TestFSMRefSpec extends AkkaSpec {
import FSM._

View file

@ -8,6 +8,7 @@ import akka.event.EventHandler
import akka.dispatch.Future
import akka.util.duration._
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class TestProbeSpec extends AkkaSpec {
"A TestProbe" must {

View file

@ -4,6 +4,7 @@ import org.scalatest.matchers.MustMatchers
import org.scalatest.{ BeforeAndAfterEach, WordSpec }
import akka.util.Duration
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class TestTimeSpec extends AkkaSpec with BeforeAndAfterEach {
val tf = Duration.timeFactor