I am using Play! 2.0.2, Akka 2.0.2 and Java 1.6 .
My System configuration :
- Quad core processor
- 4 GB RAM
- 60 GB HHD
I have written a sample application using akka and want to learn about how to set thread pool size, min/max pool size, core-pool-size in configuration file for benchmarking my sample example.
Do I really have to configure about thread pool size as per my system configuration
Hi,
I am facing issues running akka with JBOSS. I have two WAR(s) both having akka-actor and akka remote dependencies. When I try to load both of them I get the below error:
Caused by: org.jboss.msc.service.DuplicateServiceException: Service jboss.pojo."org.jboss.netty.internal.LoggerConfigurator".DESCRIBED is already registered
It works perfectly fine when I just have one WAR deployed. This
How can I do that?
Is there any reference of properties I can override in application.conf?�
There is this:�http://www.playframework.org/documentation/2.0/AkkaCore, but I'm not sure how can I possibly override this values as they seem�buried�in reference.conf which is HOCON and not plain key-value.�
I'm generally not sure how I can use hocon format instead of key-value for application.conf so I'd
Hi
I'm using Tomcat 5.5.17 with jdk 1.5.0_14, and i want to know what is the
best way to check if the tomcat thread pool is working all right.
I think I have the same problem as reported here:
http://marc.info/?l=tomcat-user&m=117036808932698&w=2
(but the user does not tell how he fixed the problem)
The CPU and MEMORY usage of the server (where tomcat is) are good (low), and
the database server it
I'm wondering the impact of long delays in scheduled events, on the order
of perhaps one day; in the past I've implemented this as an event to hold
an expected delay and compares against a start time stored as actor state.
The downside of this is frequent tick events sent to check this
duration(which may have some socket overhead even when sending to self()),
which looking at LightArrayRevolverScheduler
Hi,
I was wondering if there were any strategies or published code for
detecting and dealing with thread pool starvation in Akka apps, to save me
from duplicating work?
I've seen https://groups.google.com/forum/#!topic/akka-user/JrDWOPeOFy8 but
it doesn't directly address detecting this issue when it occurs
accidentally.
We have a high throughput Akka app, and we have occasionally
Hi, I've ported my scala actor sample to akka. Now, I've got problems
running my unit tests.
I get 2 different types of errors:
java.lang.IllegalStateException: Can't build a new thread pool for a
dispatcher that is already up and running
And the other:
java.lang.IllegalStateException: Can't build a new thread pool for a
dispatcher that is already up and running
at
se
Hi,
By default activeMQ uses a thread per destination,
is this destination topic/queue or includes the clients also
ie, if we have three publishers sending messages to a topic and eight
subscribers listening to it.
How many threads are there in the broker for that topic. ( 1 or (3+8+1) )
--
View this message in context: http://old.nabble.com/activeMQ-thread-pool-tp29041258p29041258.html
Sent
Are there some integration points within the Akka framework where it is
possible to get information about individual thread pool usage?
Regards,
Nils-Helge Garli Hegvik
You received this message because you are subscribed to the Google Groups "Akka User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email to
[email protected]
Hi,
As I understood that the fork-join-executor is the default dispatcher when
non is provided when creating the actor system
Can someone explain me the following:
1. fork-join-executor {
2. # Min number of threads to cap factor-based parallelism number to
3. parallelism-min = 8
4.
5. # The parallelism factor is used to determine thread pool size using
the
6. #
Hi,
In most cases, fork-join-executor is better than thread-pool-executor,
however I'm wondering what's the best scenario to use thread-pool-executor.
Thanks
Leon
You received this message because you are subscribed to the Google Groups "Akka User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email to
[email protected].
Is there any way to set the name of an akka thread? I have two dispatchers, one uses the default fork-join executor and another is a pinned thread-pool executor. The fork-join threads are named "[AkkaSystemName]-[DispatcherName]-[id]", however the pinned dispatcher threads are all named "[AkkaSystemName]-[id]" which makes it somewhat difficult to figure out what I am looking at in a thread dump
Hi all,
I have two questions:
1. How can I get the size of Play's Akka scheduler thread pool size?
What I mean by the "Play's Akka scheduler" is the scheduler from "Akka.system.scheduler()" invocation.
2. Based on this following code in Play's controller:
� � @BodyParser.Of(BodyParser.Json.class)
� � public static Result asyncAck(){
� � � � JsonNode json = request().body().asJson();
� � � � int
I need async http, and I think it really needs to be driven by Akka's thread pool management.
Looking at this thread:
https://groups.google.com/forum/#!msg/akka-user/693o3hMBgyw/bjFc9blOLioJ
and the async-http-client and spray-can-client.
I'm in a Java centric environment, which mostly rules out spray-can, but I want akka integrated thread pool for async http calls.
Please correct me if I'm
Hi,
I have a question about ConnectionPool: Connections in pool are always
opened and when a thread requests for a connection, pool gives an opened
connection OR
opens and connects as a request receives? In another way, destroying or
releasing connections will disconnect the connection or just marks it as an
unused connection?
Thanks
Hossein Younesi Vaghar
I have the following code in my project:
System.out.println(">>>>>>>>>> " +
config.analyticsDatasourceJNDIName());
System.out.println(String.format(">>>>>>>>>> %s = %s",
KEY_ANALYTICS_DATASOURCE,
ictxt.lookup(config.analyticsDatasourceJNDIName())));
registry.bind(KEY_ANALYTICS_DATASOURCE,
ictxt.lookup(config.analyticsDatasourceJNDIName()));
System.out.println(String
For the last week or so I've been hacking on implementing an Avro RPC
server on top of the Tornado IOLoop. It's pretty barebones right now and
hasn't been tested very thoroughly, so user beware. It comes with a
single-threaded server and a server that uses a thread pool to execute the
responder requests. I figured I'd throw it out there in case anyone is
interested.
Source here:
https://github.com
Hi -
The answer may be as simple as 'that's the way it is, but what we observe is
not ideal:
Basically a pool of 'listeners'
(jms:topic:super_topic?concurrentConsumers=10) all receive the same message,
whereas the ideal scenario would be only one thread handles each msg and to
process different messages concurrently in the thread pool.
This (obviously) works fine with queues since only one consumer
My desired flow is:
endpoint routes to bean
bean creates multiple child messages from source
split on body
child messages process in parallel, up to a max
aggregate results
reply w/ aggregated results
I've tried several different configurations. I've been able to make it all
process like a queue, or wide open parallel. Wide open parallel exhausts my
DB pool.
Here are the current route
Hello everyone,
I am looking for a way to use a common thread pool for different seda
endpoint. For now I have defined a custom thread pool in camel context
called after each seda endpoints. For example I have defined :
in camel context, this is used as followed:
from("seda:testPool1?waitForTaskToComplete=Never")
.threads().executorServiceRef("testPool")
.to("testProcessor");
from("seda:testPool2
