From 52b6dfe188e78e8c9bb68e38f452601991ae7b56 Mon Sep 17 00:00:00 2001
From: Martin Krasser <krasserm@googlemail.com>
Date: Sat, 19 Jun 2010 15:56:29 +0200
Subject: [PATCH] Producer trait with default implementation of Actor.receive

---
 akka-camel/src/main/scala/Producer.scala                   | 5 +++++
 akka-camel/src/test/scala/ProducerFeatureTest.scala        | 1 -
 akka-samples/akka-sample-camel/src/main/scala/Actors.scala | 3 ---
 3 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/akka-camel/src/main/scala/Producer.scala b/akka-camel/src/main/scala/Producer.scala
index 7aca16f956..9a68b8d57f 100644
--- a/akka-camel/src/main/scala/Producer.scala
+++ b/akka-camel/src/main/scala/Producer.scala
@@ -133,6 +133,11 @@ trait Producer { this: Actor =>
     }
   }
 
+  /**
+   * Default implementation of Actor.receive
+   */
+  protected def receive = produce
+
   /**
    * Creates a new in-only Exchange.
    */
diff --git a/akka-camel/src/test/scala/ProducerFeatureTest.scala b/akka-camel/src/test/scala/ProducerFeatureTest.scala
index 6f1f39abeb..eda866e064 100644
--- a/akka-camel/src/test/scala/ProducerFeatureTest.scala
+++ b/akka-camel/src/test/scala/ProducerFeatureTest.scala
@@ -11,7 +11,6 @@ import se.scalablesolutions.akka.actor.Actor._
 object ProducerFeatureTest {
   class TestProducer(uri: String) extends Actor with Producer {
     def endpointUri = uri
-    def receive = produce
   }
 }
 
diff --git a/akka-samples/akka-sample-camel/src/main/scala/Actors.scala b/akka-samples/akka-sample-camel/src/main/scala/Actors.scala
index f9feaa7f4d..7ab8b0dae5 100644
--- a/akka-samples/akka-sample-camel/src/main/scala/Actors.scala
+++ b/akka-samples/akka-sample-camel/src/main/scala/Actors.scala
@@ -32,8 +32,6 @@ class Producer1 extends Actor with Producer {
 
   override def oneway = false // default
   override def async = true   // default
-
-  protected def receive = produce
 }
 
 class Consumer1 extends Actor with Consumer with Logging {
@@ -102,7 +100,6 @@ class Publisher(name: String, uri: String) extends Actor with Producer {
   self.id = name
   def endpointUri = uri
   override def oneway = true
-  protected def receive = produce
 }
 
 class PublisherBridge(uri: String, publisher: ActorRef) extends Actor with Consumer {