From 90ef28f91e07a091dd2789469ccf7024d4d8c09e Mon Sep 17 00:00:00 2001 From: Martin Krasser Date: Sat, 13 Aug 2011 10:46:46 +0200 Subject: [PATCH] Avoid MatchError in typed and untyped consumer publishers --- .../src/main/scala/akka/camel/TypedConsumerPublisher.scala | 1 + akka-camel/src/main/scala/akka/camel/ConsumerPublisher.scala | 1 + 2 files changed, 2 insertions(+) diff --git a/akka-camel-typed/src/main/scala/akka/camel/TypedConsumerPublisher.scala b/akka-camel-typed/src/main/scala/akka/camel/TypedConsumerPublisher.scala index a51f8ab42f..7b30ae5d74 100644 --- a/akka-camel-typed/src/main/scala/akka/camel/TypedConsumerPublisher.scala +++ b/akka-camel-typed/src/main/scala/akka/camel/TypedConsumerPublisher.scala @@ -21,6 +21,7 @@ private[camel] class TypedConsumerPublishRequestor extends PublishRequestor { def receiveActorRegistryEvent = { case ActorRegistered(_, actor, typedActor) ⇒ for (event ← ConsumerMethodRegistered.eventsFor(actor, typedActor)) deliverCurrentEvent(event) case ActorUnregistered(_, actor, typedActor) ⇒ for (event ← ConsumerMethodUnregistered.eventsFor(actor, typedActor)) deliverCurrentEvent(event) + case _ ⇒ () } } diff --git a/akka-camel/src/main/scala/akka/camel/ConsumerPublisher.scala b/akka-camel/src/main/scala/akka/camel/ConsumerPublisher.scala index 22cf5e76a5..3045643cfb 100644 --- a/akka-camel/src/main/scala/akka/camel/ConsumerPublisher.scala +++ b/akka-camel/src/main/scala/akka/camel/ConsumerPublisher.scala @@ -22,6 +22,7 @@ private[camel] class ConsumerPublishRequestor extends PublishRequestor { def receiveActorRegistryEvent = { case ActorRegistered(_, actor, None) ⇒ for (event ← ConsumerActorRegistered.eventFor(actor)) deliverCurrentEvent(event) case ActorUnregistered(_, actor, None) ⇒ for (event ← ConsumerActorUnregistered.eventFor(actor)) deliverCurrentEvent(event) + case _ ⇒ () } }