I'm using akka cluster sharding & spray to providing RESTful service. And
It works well for the past few month.
But recently our project failed to package because test cases are not pass
sometimes. It is quite strange, because sometimes it package successfully,
but most of time it doesn't.
Here are some key classes in my project:
Boot.scala (start the whole cluster)
object Boot {
val localhostAddress = NetworkUtil.getIpaddress
val config = localhostAddress match {
case Success(addr) =>
ConfigFactory.parseString(s"""akka.remote.netty.tcp.hostname="${addr}"""")
.withFallback(ConfigFactory.load())
case Failure(exp) =>
throw new Exception("failed to get ip address")
ConfigFactory.load()
}
implicit val system = ActorSystem(GlobalConfig.clusterName, config)
val settings = AppSettings.default
val service = system.actorOf(Props[ServiceActor], "service")
val esAddr =
config.getString("elasticsearch.default.url").stripPrefix("http://";)
EntityStore.init(esAddr)
//implicit value for Http.Bind()
implicit val timeout = new Timeout(5.seconds)
//start cluster sharding
ClusterSharding(system).start(
typeName = ActionWorkerActor.shardName,
entryProps = Some(ActionWorkerActor.props()),
idExtractor = ActionWorkerActor.idExtractor,
shardResolver = ActionWorkerActor.shardResolver)
//start cluster tool
ClusterTool.init
def main(args: Array[String]): Unit = {
IO(Http) ? Http.Bind(service, interface = settings.bind.host, port =
settings.bind.port)
}
}
one test case example: (other test cases are similar to this one, I didn't
use multi-jvm testing)
class EndUserSpec extends FunSuite with AmsRoute with ScalatestRouteTest {
implicit val routeTestTimeout = RouteTestTimeout(60 second)
def actorRefFactory: ActorRefFactory = Boot.system
var id = BoxTestHelper.createNewBoxAlert
val userHeader = RawHeader("userId", "limhu")
test("new -> escalate to user") {
Thread.sleep(3000)
val postJson = """{
| "comment": "no comment",
| "escalateTo": [
| "xinszhou"
| ]
|}""".stripMargin
Post( s"""/ams/${id}/escalate2user""",
HttpEntity(ContentTypes.`application/json`,
postJson)).withHeaders(userHeader) ~> routes ~> check {
assert(status === OK)
}
assert(TestHelper.esStatus(id) === "escalated")
}
id = "icam-testams-1488799388"
test("Escalated -> confirm -> Pending close") {
val postJson = """{
| "comment": "no comment",
|
| "confirm_result": [
| {
| "file_id": "31679491830",
| "name": "xxx(1).docx"
| }
| ]
|}""".stripMargin
Post( s"""/ams/${id}/confirm""",
HttpEntity(ContentTypes.`application/json`,
postJson)).withHeaders(userHeader) ~> routes ~> check {
assert(status === OK)
}
println(TestHelper.esStatus(id))
assert(TestHelper.esStatus(id) != "escalated")
}
}
assembly.sbt (I explicit set parallelExecution to false)
assemblySettings
coverageEnabled.in(Test, test) := true
//coverageEnabled := true
//coverageMinimum := 80
//coverageFailOnMinimum := true
//parallelExecution := false
parallelExecution in Test := false
assemblyOption in assembly ~= {
_.copy(cacheOutput = false)
}
mergeStrategy in assembly := {
case PathList("org", "joda", "convert", xs@_*) => MergeStrategy.first
case "OSGI-INF/bundle.info" => MergeStrategy.filterDistinctLines
case "META-INF/maven/jline/jline/pom.properties" => MergeStrategy.first
case "META-INF/maven/jline/jline/pom.xml" => MergeStrategy.first
case "unwanted.txt" => MergeStrategy.discard
case x =>
val oldStrategy = (mergeStrategy in assembly).value
oldStrategy(x)
}
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
