scala - Java, Akka Actor and Bounded Mail Box -


i have following configuration in application.conf:

bounded-mailbox {   mailbox-type = "akka.dispatch.boundedmailbox"   mailbox-capacity = 100   mailbox-push-timeout-time = 3s }  akka {      loggers = ["akka.event.slf4j.slf4jlogger"]     loglevel = info     daemonic = on }

this way how configured actor

public class mytestactor extends untypedactor implements requiresmessagequeue<boundedmessagequeuesemantics>{       @override     public void onreceive(object message) throws exception {         if (message instanceof string){               thread.sleep(500);              system.out.println("message = " + message);         }         else {             system.out.println("unknown message " );         }      } }

now how initate actor:

mytestactor = myactorsystem.actorof(props.create(mytestactor.class).withmailbox("bounded-mailbox"), "simple-actor");

after it, in code i'm sending 3000 messages actor.

  (int =0;i<3000;i++){         mytestactor.tell(guestname, null);}

what expect see exception queues full, messages printed inside onreceive method every half second, nothing happened. believe mailbox configuration not applied.

what doing wrong?

updated: created actor subscribes dead letter events:

deadletteractor = myactorsystem.actorof(props.create(deadlettermonitor.class),"deadletter-monitor");

and installed kamon queues monitoring:

after sending 3000 messages sent actor, kamin shows me following:

actor: user/simple-actor   mailbox size:  min: 100   avg.: 100.0  max: 101  actor: system/deadletterlistener   mailbox size:  min: 0   avg.: 0.0  max: 0  actor: system/deadletter-monitor   mailbox size:  min: 0   avg.: 0.0  max: 0

by default akka discards overflowing messages deadletters , actor doesn't stop processing: https://github.com/akka/akka/blob/876b8045a1fdb9cdd880eeab8b1611aa976576f6/akka-actor/src/main/scala/akka/dispatch/mailbox.scala#l411

but sending thread blocked on interval configured mailbox-push-timeout-time before discarding message. try decrease 1ms , see following test pass:

import java.util.concurrent.atomic.atomicinteger  import akka.actor._ import com.typesafe.config.config import com.typesafe.config.configfactory._ import org.specs2.mutable.specification  class boundedactorspec extends specification {   args(sequential = true)    def config: config = load(parsestring(     """     bounded-mailbox {       mailbox-type = "akka.dispatch.boundedmailbox"       mailbox-capacity = 100       mailbox-push-timeout-time = 1ms     }     """))    val system = actorsystem("system", config)    "some messages should go dead letters" in {     system.eventstream.subscribe(system.actorof(props(classof[deadlettermetricsactor])), classof[deadletter])     val mytestactor = system.actorof(props(classof[mytestactor]).withmailbox("bounded-mailbox"))     (i  <- 0 until 3000) {       mytestactor.tell("guestname", null)     }     thread.sleep(100)     system.shutdown()     system.awaittermination()     deadlettermetricsactor.deadlettercount.get must greaterthan(0)   } }  class mytestactor extends actor {   def receive = {     case message: string =>       thread.sleep(500)       println("message = " + message);     case _ => println("unknown message")   } }  object deadlettermetricsactor {   val deadlettercount = new atomicinteger }  class deadlettermetricsactor extends actor {   def receive = {     case _: deadletter => deadlettermetricsactor.deadlettercount.incrementandget()   } }

Comments

Post a Comment

Popular posts from this blog

java - Spring Data JPA: Why findOne(id) executing delete query internally? -

i have 1 application using @manytomany annotation link 2 different entities 1 parent entity. not sure if have implemented properly. when execute .findone() on parent entity's repository find it, @ first fetch data along executing delete queries internally delete record mapping table (a table jpa creates after adding @manytomany annotation.). following generated sql queries , code snippet: java class @entity @table(name = "inventory") public class inventory { @id long id; // many other properties @manytomany(fetch=fetchtype.lazy) private list<stream> streams; @manytomany(fetch=fetchtype.lazy) private list<subject> subjects; } there no other annotation i've put in stream , subject entity class link inventory class. when run app, create following tables: inventory stream subject inventory_stream inventory_subject (inventory_stream , inventory_subject, 2 tables created automatically, don't k...
Read more

python - Mongodb How to add addtional information when aggregating? -

i beginner , wrote line pipeline works, wanna add other information output, screen name , or number of tweets.i tried add under $group gave me syntax error everytime here pipeline: def make_pipeline(): # complete aggregation pipeline pipeline = [ { '$match': { "user.statuses_count": {"$gt":99 }, "user.time_zone": "brasilia" } }, { "$group": { "_id": "$user.id", "followers": { "$max": "$user.followers_count" } } }, { "$sort": { "followers": -1 } }, { "$limit" : 1 } ]; i using on example : { "_id" : objectid("5304e2e3cc9e684aa98bef97"), "text" : "first week of school on :p", "in_reply_to_status_id" : null, "retweet_count" : null, ...
Read more

java - Incorrect order of records in M-M relationship in hibernate -

Image
i have 4 records in bridge table in mysql database. using @manytomany in hibernate, accurate order of employees incorrect incorrect of projects. following required material figure out doing mistake. this source. @entity @table(name="project") public class projectbean { @id @generatedvalue @column(name="project_id") private int projectid; @column(name="title") private string projecttitle; @manytomany(mappedby="projects") private collection<employeebean> employees; public projectbean() { employees = new arraylist<employeebean>(); } //getters & setters } @entity @table(name="employee") public class employeebean { @id @generatedvalue @column(name="employee_id") private int employee_id; @column(name="first_name") private string ...
Read more