=clt #23215 fail with nicer message if PubSubMediator gets null message (#23216)

* =clt #23215 fail with nicer message if PubSubMediator gets null message * Update DistributedPubSubMediator.scala
2017-08-21 02:02:15 +09:00 · 2017-08-21 02:02:15 +09:00 · d07df2b917
commit d07df2b917
parent bb106aa27e
1 changed files with 1 additions and 0 deletions
--- a/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala
+++ b/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala
@ -402,6 +402,7 @@ object DistributedPubSubMediator {
     */
    def wrapIfNeeded: Any ⇒ Any = {
      case msg: RouterEnvelope ⇒ MediatorRouterEnvelope(msg)
+      case null                ⇒ throw InvalidMessageException("Message must not be null")
      case msg: Any            ⇒ msg
    }
  }