You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iota.apache.org by to...@apache.org on 2016/07/21 23:37:54 UTC
[03/10] incubator-iota git commit: Fixing issues on Ensemble test
Fixing issues on Ensemble test
Project: http://git-wip-us.apache.org/repos/asf/incubator-iota/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-iota/commit/db380c08
Tree: http://git-wip-us.apache.org/repos/asf/incubator-iota/tree/db380c08
Diff: http://git-wip-us.apache.org/repos/asf/incubator-iota/diff/db380c08
Branch: refs/heads/master
Commit: db380c08d401dcf1c48b8df019d3dff1eb78f16e
Parents: c96d829
Author: Barbara Gomes <ba...@gmail.com>
Authored: Tue Jul 19 11:20:46 2016 -0700
Committer: Barbara Gomes <ba...@gmail.com>
Committed: Tue Jul 19 11:20:46 2016 -0700
----------------------------------------------------------------------
fey-core/src/test/scala/org/apache/iota/fey/EnsembleSpec.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/db380c08/fey-core/src/test/scala/org/apache/iota/fey/EnsembleSpec.scala
----------------------------------------------------------------------
diff --git a/fey-core/src/test/scala/org/apache/iota/fey/EnsembleSpec.scala b/fey-core/src/test/scala/org/apache/iota/fey/EnsembleSpec.scala
index f968804..e7e3554 100644
--- a/fey-core/src/test/scala/org/apache/iota/fey/EnsembleSpec.scala
+++ b/fey-core/src/test/scala/org/apache/iota/fey/EnsembleSpec.scala
@@ -125,7 +125,7 @@ class EnsembleSpec extends BaseAkkaSpec{
val advEnsembleJson = getJSValueFromString(Utils_JSONTest.ensemble_test_json)
var advEnsembleRef:TestActorRef[Ensemble] = _
- var advEnsembleState: Ensemble = ensembleRef.underlyingActor
+ var advEnsembleState: Ensemble = _
var paramsRef: ActorRef = _
var scheduleRef: ActorRef = _
val generalScheduleTB = TestProbe("GENERAL-SCHEDULE")
@@ -213,7 +213,7 @@ class EnsembleSpec extends BaseAkkaSpec{
monitor.expectMsgClass(classOf[Monitor.STOP])
monitor.expectMsgClass(classOf[Monitor.RESTART])
monitor.expectMsgClass(classOf[Monitor.START])
- ensembleState = ensembleRef.underlyingActor
+ advEnsembleState = advEnsembleRef.underlyingActor
}
"keep ensemble actorRef when restarted" in {
TestProbe().expectActor(s"${parent.ref.path}/${(advEnsembleJson \ JSON_PATH.GUID).as[String]}") should equal(advEnsembleRef)
@@ -263,7 +263,7 @@ class EnsembleSpec extends BaseAkkaSpec{
val backEnsembleJson = getJSValueFromString(Utils_JSONTest.ensemble_backoff_test_json)
var backEnsembleRef:TestActorRef[Ensemble] = _
- var backEnsembleState: Ensemble = ensembleRef.underlyingActor
+ var backEnsembleState: Ensemble = _
var backParamsRef: ActorRef = _
var backScheduleRef: ActorRef = _
val backprocessParamsTB = TestProbe("BACKOFF")