rabbitmq - How to throttle ServiceStack Messaging EventHandler -

-

i know sounds anti-pattern, have requirement dictates flow of messages service (cisco phones) configurable i.e. throttling.

there times when our phone system can not handle load of messages being routed servicestack via rabbitmq broker (work queue), it's during these peak times need curb flow of messages. i've read this qa, don't know if that's applicable or not. should nak messages based on throttling algorithm in client handler?

thank you, stephen

by default there 1 worker thread (per message type) that's used process request, can add thread.sleep() in service delay processing of request next request gets processed after previous 1 has finished.


Comments

Post a Comment

Popular posts from this blog

java - Unable to make sub reports with Jasper -

-
i using jaspersoft studio create reports. having sub report in jasper main report. problem unable make work, because if add sub report detail band of main report, sub report generated number of times, row row, entire sub report repeated in number of pages. can't put in summery band due same reason. i unable put in column footer band or other footers because displays below error net.sf.jasperreports.engine.jrexception: net.sf.jasperreports.engine.jrruntimeexception: subreport overflowed on band not support overflow. @ com.jaspersoft.studio.editor.preview.view.control.reportcontroler.fillreport(reportcontroler.java:467) @ com.jaspersoft.studio.editor.preview.view.control.reportcontroler.access$18(reportcontroler.java:442) @ com.jaspersoft.studio.editor.preview.view.control.reportcontroler$4.run(reportcontroler.java:334) @ org.eclipse.core.internal.jobs.worker.run(worker.java:54) caused by: net.sf.jasperreports.engine.jrruntimeexception: subreport overflowe...
Read more

scala - play framework: Modules were resolved with conflicting cross-version suffixes -

-
i want use elastic search play framework followed this guide here build.sbt file name := """es-with-play""" version := "1.0-snapshot" lazy val root = (project in file(".")).enableplugins(playscala) scalaversion := "2.11.1" librarydependencies ++= seq( jdbc, anorm, cache, ws, "com.clever-age" % "play2-elasticsearch" % "1.4-snapshot" ) resolvers += "sonatype oss snapshots" @ "https://oss.sonatype.org/content/repositories/snapshots" and in play console when compile code gives following errors [error] modules resolved conflicting cross-version suffixes in {file:/media/sara/new%20volume/programs/programs/play/es-with-play/}root: [error] com.jsuereth:scala-arm _2.11, _2.10 [error] com.typesafe.play:play-functional _2.11, _2.10 [error] com.typesafe.akka:akka-actor _2.11, _2.10 [error] com.typesafe.play:play-json _2.11, _2.10 [error] com.type...
Read more

Passing Variables from AngelScript to C++ -

-
i want pass variable angelscript c++. managed pass functions angelscript c++ , vice versa. can pass variables c++ angelscript, can't figure out how other way round. manual didn't me or have overseen part. can please give me hint? edit: as mentioned in comment here managed do. in test.as file: int add(int a, int b) { print("hello world, i'm angelscript\n"); multi(5, 13); print("c " + c + "\n"); return (a + b); } my test.cpp file: int multi(int x, int y) { int z = x * y; cout << "x aus dem skript: " << x << endl; cout << "y aus dem skript: " << y << endl; printf("ergebnis von multi x * y: %d\n", z); return z; } void print(string &msg) { printf("%s", msg.c_str()); } int _tmain(int argc, _tchar* argv[]) { int r; int c = 42; asiscriptengine *engine = ascreatescriptengine(angelscript_version); ...
Read more