0

我正在开发一个 Akka 演员，它会以 type 的消息进行响应PutAck[Try[String]]。问题不在于如何开发参与者本身，而在于单元测试。

鉴于以下演员代码

private def put(store: Map[String, Array[Byte]], key: String, value: Array[Byte]) = {
  try {
    val newStore = store + (Objects.requireNonNull(key) -> value)
    sender ! PutAck(Success(key))
    context.become(nonEmptyMap(newStore))
  } catch {
    case ex: Exception =>
      sender ! PutAck(Failure(ex))
  }
}

我希望通过以下测试对其进行测试

"A Storekeeper actor" must {
  "receive an error message for a couple (null, value)" in {
    val sk = TestActorRef[Storekeeper]
    sk ! Put(null, SerializationUtils.serialize(42))
    expectMsg(PutAck(Failure(new NullPointerException())))
  }
}

不幸的是，测试失败并显示消息

assertion failed: expected PutAck(Failure(java.lang.NullPointerException)), found PutAck(Failure(java.lang.NullPointerException))

我认为失败是由于hashCode两个例外的不同。

我该如何测试这个案例？

4

1 回答 1

1

它匹配的原因是NullPointerExceptions 的实例只等于它们自己，而不是其他看似相同的实例。

相反，您可以做的是期待消息类型，将响应作为值捕获，然后断言您想要的任何内容，如下所示：

val ack = expectMsgType[PutAck[Try[String]]]
ack.value.isFailure should === (true)
ack.value.failed.get shouldBe a[NullPointerException]
于 2016-11-09T13:14:04.550 回答