raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Removed the need for passing in 'this' as log source to LoggingReceive. See #1720

Browse source
This commit is contained in:
Patrik Nordwall 2012-01-26 13:24:48 +01:00
parent 52aa4f2a64
commit 60fd3c2964
5 changed files with 19 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-docs/scala/code/akka/docs/actor/FaultHandlingDocSample.scala
View file

@ -79,7 +79,7 @@ class Worker extends Actor with ActorLogging {
var progressListener: Option[ActorRef] = None
val counterService = context.actorOf(Props[CounterService], name = "counter")
def receive = LoggingReceive(this) {
def receive = LoggingReceive {
case Start if progressListener.isEmpty ⇒
progressListener = Some(sender)
context.system.scheduler.schedule(Duration.Zero, 1 second, self, Do)
@ -143,7 +143,7 @@ class CounterService extends Actor {
storage.get ! Get(key)
}
def receive = LoggingReceive(this) {
def receive = LoggingReceive {
case Entry(k, v) if k == key && counter == None ⇒
// Reply from Storage of the initial value, now we can create the Counter
@ -206,7 +206,7 @@ class Counter(key: String, initialValue: Long) extends Actor {
var count = initialValue
var storage: Option[ActorRef] = None
def receive = LoggingReceive(this) {
def receive = LoggingReceive {
case UseStorage(s) ⇒
storage = s
storeCount()
@ -246,7 +246,7 @@ class Storage extends Actor {
val db = DummyDB
def receive = LoggingReceive(this) {
def receive = LoggingReceive {
case Store(Entry(key, count)) ⇒ db.save(key, count)
case Get(key) ⇒ sender ! Entry(key, db.load(key).getOrElse(0L))
}