Skip to content

Commit 65cd5dc

Browse files
committed
Update codes according to the new akka version.
1 parent fcb1248 commit 65cd5dc

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

tests/src/test/scala/org/apache/openwhisk/core/scheduler/queue/test/MemoryQueueTests.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import java.{lang, util}
77
import akka.actor.ActorRef
88
import akka.actor.FSM.{CurrentState, StateTimeout, SubscribeTransitionCallBack, Transition}
99
import akka.pattern.ask
10-
import akka.stream.ActorMaterializer
10+
import akka.stream.Materializer
1111
import akka.testkit.{ImplicitSender, TestActor, TestFSMRef, TestKit, TestProbe}
1212
import akka.util.Timeout
1313
import com.google.protobuf.ByteString
@@ -84,7 +84,7 @@ class MemoryQueueTests
8484
Client.forEndpoints(hostAndPorts).withPlainText().build()
8585
}
8686

87-
implicit val materializer: ActorMaterializer = ActorMaterializer()
87+
implicit val materializer = Materializer
8888

8989
def registerCallback(c: ActorRef) = {
9090
c ! SubscribeTransitionCallBack(testActor)

0 commit comments

Comments
 (0)