adding return types

This commit is contained in:
Piotr Gabryanczyk 2012-04-09 07:59:03 +01:00
parent 1b254f9f61
commit c457360dbe
3 changed files with 6 additions and 8 deletions

View file

@ -120,8 +120,8 @@ trait ProducerSupport { this: Actor ⇒
* actor). * actor).
*/ */
protected def routeResponse: Receive = { protected def routeResponse(msg: Any): Any = {
case msg if (!oneway) sender ! transformResponse(msg) if (!oneway) sender ! transformResponse(msg)
} }
} }

View file

@ -36,15 +36,15 @@ abstract class UntypedProducerActor extends UntypedActor with ProducerSupport {
*/ */
def onRouteResponse(message: AnyRef): Unit = super.routeResponse(message) def onRouteResponse(message: AnyRef): Unit = super.routeResponse(message)
final override def transformOutgoingMessage(msg: Any) : AnyRef = msg match { final override def transformOutgoingMessage(msg: Any): AnyRef = msg match {
case msg: AnyRef onTransformOutgoingMessage(msg) case msg: AnyRef onTransformOutgoingMessage(msg)
} }
final override def transformResponse(msg: Any) : AnyRef = msg match { final override def transformResponse(msg: Any): AnyRef = msg match {
case msg: AnyRef onTransformResponse(msg) case msg: AnyRef onTransformResponse(msg)
} }
final override def routeResponse : AnyRef = { final override def routeResponse(msg: Any): Any = msg match {
case msg: AnyRef onRouteResponse(msg) case msg: AnyRef onRouteResponse(msg)
} }

View file

@ -277,9 +277,7 @@ object ProducerFeatureTest {
class TestForwarder(uri: String, target: ActorRef) extends Actor with Producer { class TestForwarder(uri: String, target: ActorRef) extends Actor with Producer {
def endpointUri = uri def endpointUri = uri
override protected def routeResponse = { override protected def routeResponse(msg: Any): Any = { target forward msg }
case msg target forward msg
}
} }
class TestResponder extends Actor { class TestResponder extends Actor {