renamed tests from *Test -> *Spec
This commit is contained in:
parent
b2ba933e78
commit
4a7b7210bc
23 changed files with 27 additions and 82 deletions
|
|
@ -6,7 +6,7 @@ import org.junit.Test
|
|||
|
||||
import se.scalablesolutions.akka.dispatch.Dispatchers
|
||||
|
||||
class ActorFireForgetRequestReplyTest extends JUnitSuite {
|
||||
class ActorFireForgetRequestReplySpec extends JUnitSuite {
|
||||
|
||||
object state {
|
||||
var s = "NIL"
|
||||
|
|
@ -3,7 +3,7 @@ package se.scalablesolutions.akka.actor
|
|||
import org.scalatest.junit.JUnitSuite
|
||||
import org.junit.Test
|
||||
|
||||
class ActorRegistryTest extends JUnitSuite {
|
||||
class ActorRegistrySpec extends JUnitSuite {
|
||||
var record = ""
|
||||
class TestActor extends Actor {
|
||||
id = "MyID"
|
||||
|
|
@ -13,7 +13,7 @@ import org.junit.runner.RunWith
|
|||
import org.junit.{Test}
|
||||
|
||||
@RunWith(classOf[JUnitRunner])
|
||||
class AgentTest extends junit.framework.TestCase
|
||||
class AgentSpec extends junit.framework.TestCase
|
||||
with Suite with MustMatchers
|
||||
with ActorTestUtil with Logging {
|
||||
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
/**
|
||||
* Copyright (C) 2009-2010 Scalable Solutions AB <http://scalablesolutions.se>
|
||||
*/
|
||||
|
||||
package se.scalablesolutions.akka
|
||||
|
||||
import org.scalatest._
|
||||
|
||||
/**
|
||||
* @author <a href="http://jonasboner.com">Jonas Bonér</a>
|
||||
*/
|
||||
class AllSuite extends SuperSuite(
|
||||
|
||||
List(
|
||||
// new ActiveObjectSpec,
|
||||
// new RestManagerSpec
|
||||
)
|
||||
)
|
||||
|
||||
|
||||
|
|
@ -1,28 +0,0 @@
|
|||
package se.scalablesolutions.akka
|
||||
|
||||
import junit.framework.Test
|
||||
import junit.framework.TestCase
|
||||
import junit.framework.TestSuite
|
||||
|
||||
import se.scalablesolutions.akka.actor.{ClientInitiatedRemoteActorTest, InMemoryActorTest, ThreadBasedActorTest, SupervisorTest, RemoteSupervisorTest, SchedulerTest}
|
||||
|
||||
object AllTest extends TestCase {
|
||||
def suite(): Test = {
|
||||
val suite = new TestSuite("All Scala tests")
|
||||
/* suite.addTestSuite(classOf[SupervisorTest])
|
||||
suite.addTestSuite(classOf[RemoteSupervisorTest])
|
||||
suite.addTestSuite(classOf[ReactorBasedSingleThreadEventDrivenDispatcherTest])
|
||||
suite.addTestSuite(classOf[ReactorBasedThreadPoolEventDrivenDispatcherTest])
|
||||
suite.addTestSuite(classOf[ThreadBasedActorTest])
|
||||
suite.addTestSuite(classOf[ReactorBasedSingleThreadEventDrivenDispatcherTest])
|
||||
suite.addTestSuite(classOf[ReactorBasedThreadPoolEventDrivenDispatcherTest])
|
||||
suite.addTestSuite(classOf[ClientInitiatedRemoteActorTest])
|
||||
suite.addTestSuite(classOf[InMemoryActorTest])
|
||||
suite.addTestSuite(classOf[SchedulerTest])
|
||||
//suite.addTestSuite(classOf[TransactionClasherTest])
|
||||
*/
|
||||
suite
|
||||
}
|
||||
|
||||
def main(args: Array[String]) = junit.textui.TestRunner.run(suite)
|
||||
}
|
||||
|
|
@ -46,10 +46,8 @@ class RemoteActorSpecActorAsyncSender extends Actor {
|
|||
}
|
||||
}
|
||||
|
||||
class ClientInitiatedRemoteActorTest extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
|
||||
se.scalablesolutions.akka.config.Config.config
|
||||
class ClientInitiatedRemoteActorSpec extends JUnitSuite {
|
||||
se.scalablesolutions.akka.config.Config.config
|
||||
|
||||
val HOSTNAME = "localhost"
|
||||
val PORT1 = 9990
|
||||
|
|
@ -5,7 +5,7 @@ import org.scalatest.junit.JUnitSuite
|
|||
import org.junit.Test
|
||||
import se.scalablesolutions.akka.dispatch.Dispatchers
|
||||
|
||||
class ExecutorBasedEventDrivenDispatcherActorTest extends JUnitSuite {
|
||||
class ExecutorBasedEventDrivenDispatcherActorSpec extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
|
||||
private val unit = TimeUnit.MILLISECONDS
|
||||
|
|
@ -11,7 +11,7 @@ import java.util.concurrent.CountDownLatch
|
|||
*
|
||||
* @author Jan Van Besien
|
||||
*/
|
||||
class ExecutorBasedEventDrivenDispatcherActorsTest extends JUnitSuite with MustMatchers with ActorTestUtil {
|
||||
class ExecutorBasedEventDrivenDispatcherActorsSpec extends JUnitSuite with MustMatchers with ActorTestUtil {
|
||||
class SlowActor(finishedCounter: CountDownLatch) extends Actor {
|
||||
messageDispatcher = Dispatchers.globalExecutorBasedEventDrivenDispatcher
|
||||
id = "SlowActor"
|
||||
|
|
@ -9,7 +9,7 @@ import se.scalablesolutions.akka.dispatch.Dispatchers
|
|||
/**
|
||||
* @author Jan Van Besien
|
||||
*/
|
||||
class ExecutorBasedEventDrivenWorkStealingDispatcherTest extends JUnitSuite with MustMatchers with ActorTestUtil {
|
||||
class ExecutorBasedEventDrivenWorkStealingDispatcherSpec extends JUnitSuite with MustMatchers with ActorTestUtil {
|
||||
val poolDispatcher = Dispatchers.newExecutorBasedEventDrivenWorkStealingDispatcher("pooled-dispatcher")
|
||||
|
||||
class DelayableActor(name: String, delay: Int, finishedCounter: CountDownLatch) extends Actor {
|
||||
|
|
@ -4,7 +4,7 @@ import org.scalatest.junit.JUnitSuite
|
|||
import org.junit.Test
|
||||
import se.scalablesolutions.akka.dispatch.Futures
|
||||
|
||||
class FutureTest extends JUnitSuite {
|
||||
class FutureSpec extends JUnitSuite {
|
||||
class TestActor extends Actor {
|
||||
def receive = {
|
||||
case "Hello" =>
|
||||
|
|
@ -102,9 +102,7 @@ class InMemFailerActor extends Actor {
|
|||
}
|
||||
}
|
||||
|
||||
class InMemoryActorTest extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
|
||||
class InMemoryActorSpec extends JUnitSuite {
|
||||
@Test
|
||||
def shouldOneWayMapShouldNotRollbackStateForStatefulServerInCaseOfSuccess = {
|
||||
val stateful = new InMemStatefulActor(2)
|
||||
|
|
@ -3,7 +3,7 @@ package se.scalablesolutions.akka.actor
|
|||
import org.scalatest.junit.JUnitSuite
|
||||
import org.junit.Test
|
||||
|
||||
class MemoryFootprintTest extends JUnitSuite {
|
||||
class MemoryFootprintSpec extends JUnitSuite {
|
||||
class Mem extends Actor {
|
||||
def receive = {
|
||||
case _ => {}
|
||||
|
|
@ -13,7 +13,7 @@ import net.lag.logging.Logger
|
|||
* <p/>
|
||||
* Inspired by the version contributed by Yura Taras and modified by Isaac Gouy.
|
||||
*/
|
||||
class PerformanceTest extends JUnitSuite {
|
||||
class PerformanceSpec extends JUnitSuite {
|
||||
|
||||
@Test
|
||||
def dummyTest = assert(true)
|
||||
|
|
@ -6,7 +6,7 @@ import org.junit.Test
|
|||
|
||||
import se.scalablesolutions.akka.dispatch.Dispatchers
|
||||
|
||||
class ReactorBasedSingleThreadEventDrivenDispatcherActorTest extends JUnitSuite {
|
||||
class ReactorBasedSingleThreadEventDrivenDispatcherActorSpec extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
|
||||
private val unit = TimeUnit.MILLISECONDS
|
||||
|
|
@ -5,7 +5,7 @@ import org.scalatest.junit.JUnitSuite
|
|||
import org.junit.Test
|
||||
import se.scalablesolutions.akka.dispatch.Dispatchers
|
||||
|
||||
class ReactorBasedThreadPoolEventDrivenDispatcherActorTest extends JUnitSuite {
|
||||
class ReactorBasedThreadPoolEventDrivenDispatcherActorSpec extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
|
||||
private val unit = TimeUnit.MILLISECONDS
|
||||
|
|
@ -71,8 +71,7 @@ object Log {
|
|||
/**
|
||||
* @author <a href="http://jonasboner.com">Jonas Bonér</a>
|
||||
*/
|
||||
class RemoteSupervisorTest extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
class RemoteSupervisorSpec extends JUnitSuite {
|
||||
|
||||
se.scalablesolutions.akka.config.Config.config
|
||||
|
||||
|
|
@ -6,7 +6,7 @@ import org.scalatest.junit.JUnitSuite
|
|||
import org.junit.Test
|
||||
|
||||
|
||||
class SchedulerTest extends JUnitSuite {
|
||||
class SchedulerSpec extends JUnitSuite {
|
||||
|
||||
@Test def schedulerShouldSchedule = {
|
||||
/*
|
||||
|
|
@ -17,7 +17,7 @@ case class MyMessage(val id: String, val value: Tuple2[String, Int]) {
|
|||
}
|
||||
|
||||
|
||||
class SerializerTest extends JUnitSuite {
|
||||
class SerializerSpec extends JUnitSuite {
|
||||
@Test
|
||||
def shouldSerializeString = {
|
||||
val f = Foo("debasish")
|
||||
|
|
@ -7,7 +7,7 @@ import org.junit.{Test, Before, After}
|
|||
import se.scalablesolutions.akka.remote.{RemoteServer, RemoteClient}
|
||||
import se.scalablesolutions.akka.dispatch.Dispatchers
|
||||
|
||||
object ServerInitiatedRemoteActorTest {
|
||||
object ServerInitiatedRemoteActorSpec {
|
||||
val HOSTNAME = "localhost"
|
||||
val PORT = 9990
|
||||
var server: RemoteServer = null
|
||||
|
|
@ -55,8 +55,8 @@ object ServerInitiatedRemoteActorTest {
|
|||
}
|
||||
}
|
||||
|
||||
class ServerInitiatedRemoteActorTest extends JUnitSuite {
|
||||
import ServerInitiatedRemoteActorTest._
|
||||
class ServerInitiatedRemoteActorSpec extends JUnitSuite {
|
||||
import ServerInitiatedRemoteActorSpec._
|
||||
|
||||
import Actor.Sender.Self
|
||||
se.scalablesolutions.akka.config.Config.config
|
||||
|
|
@ -87,7 +87,7 @@ class ServerInitiatedRemoteActorTest extends JUnitSuite {
|
|||
@Test
|
||||
def shouldSendOneWay = {
|
||||
val actor = RemoteClient.actorFor(
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorTest$RemoteActorSpecActorUnidirectional",
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorSpec$RemoteActorSpecActorUnidirectional",
|
||||
5000L,
|
||||
HOSTNAME, PORT)
|
||||
val result = actor ! "OneWay"
|
||||
|
|
@ -98,7 +98,7 @@ class ServerInitiatedRemoteActorTest extends JUnitSuite {
|
|||
@Test
|
||||
def shouldSendReplyAsync = {
|
||||
val actor = RemoteClient.actorFor(
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorTest$RemoteActorSpecActorBidirectional",
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorSpec$RemoteActorSpecActorBidirectional",
|
||||
5000L,
|
||||
HOSTNAME, PORT)
|
||||
val result = actor !! "Hello"
|
||||
|
|
@ -110,7 +110,7 @@ class ServerInitiatedRemoteActorTest extends JUnitSuite {
|
|||
def shouldSendRemoteReply = {
|
||||
implicit val timeout = 500000000L
|
||||
val actor = RemoteClient.actorFor(
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorTest$RemoteActorSpecActorBidirectional",
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorSpec$RemoteActorSpecActorBidirectional",
|
||||
timeout,
|
||||
HOSTNAME, PORT)
|
||||
|
||||
|
|
@ -126,7 +126,7 @@ class ServerInitiatedRemoteActorTest extends JUnitSuite {
|
|||
def shouldSendReceiveException = {
|
||||
implicit val timeout = 500000000L
|
||||
val actor = RemoteClient.actorFor(
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorTest$RemoteActorSpecActorBidirectional",
|
||||
"se.scalablesolutions.akka.actor.ServerInitiatedRemoteActorSpec$RemoteActorSpecActorBidirectional",
|
||||
timeout,
|
||||
HOSTNAME, PORT)
|
||||
try {
|
||||
|
|
@ -15,8 +15,7 @@ import org.junit.Test
|
|||
/**
|
||||
* @author <a href="http://jonasboner.com">Jonas Bonér</a>
|
||||
*/
|
||||
class SupervisorTest extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
class SupervisorSpec extends JUnitSuite {
|
||||
|
||||
var messageLog: BlockingQueue[String] = new LinkedBlockingQueue[String]
|
||||
var oneWayLog: BlockingQueue[String] = new LinkedBlockingQueue[String]
|
||||
|
|
@ -6,8 +6,7 @@ import org.junit.Test
|
|||
|
||||
import se.scalablesolutions.akka.dispatch.Dispatchers
|
||||
|
||||
class ThreadBasedActorTest extends JUnitSuite {
|
||||
import Actor.Sender.Self
|
||||
class ThreadBasedActorSpec extends JUnitSuite {
|
||||
|
||||
private val unit = TimeUnit.MILLISECONDS
|
||||
|
||||
|
|
@ -11,7 +11,7 @@ import org.junit.{Test, Before}
|
|||
|
||||
import se.scalablesolutions.akka.actor.Actor
|
||||
|
||||
class ThreadBasedDispatcherTest extends JUnitSuite {
|
||||
class ThreadBasedDispatcherSpec extends JUnitSuite {
|
||||
private var threadingIssueDetected: AtomicBoolean = null
|
||||
val key1 = new Actor { def receive = { case _ => {}} }
|
||||
val key2 = new Actor { def receive = { case _ => {}} }
|
||||
Loading…
Add table
Add a link
Reference in a new issue