Fixes according to review. #2413
This commit is contained in:
parent
08ef942242
commit
0988101881
7 changed files with 20 additions and 20 deletions
|
|
@ -41,8 +41,8 @@ akka {
|
||||||
# Toggles whether threads created by this ActorSystem should be daemons or not
|
# Toggles whether threads created by this ActorSystem should be daemons or not
|
||||||
daemonic = off
|
daemonic = off
|
||||||
|
|
||||||
# JVM shutdown, System.exit(-1), in case of a fatal error, such as
|
# JVM shutdown, System.exit(-1), in case of a fatal error,
|
||||||
# OutOfMemoryError
|
# such as OutOfMemoryError
|
||||||
jvm-exit-on-fatal-error = on
|
jvm-exit-on-fatal-error = on
|
||||||
|
|
||||||
actor {
|
actor {
|
||||||
|
|
@ -107,8 +107,8 @@ akka {
|
||||||
# resizer below
|
# resizer below
|
||||||
router = "from-code"
|
router = "from-code"
|
||||||
|
|
||||||
# number of children to create in case of a non-direct router; this
|
# number of children to create in case of a non-direct router;
|
||||||
# setting is ignored if routees.paths is given
|
# this setting is ignored if routees.paths is given
|
||||||
nr-of-instances = 1
|
nr-of-instances = 1
|
||||||
|
|
||||||
# within is the timeout used for routers containing future calls
|
# within is the timeout used for routers containing future calls
|
||||||
|
|
@ -231,8 +231,8 @@ akka {
|
||||||
# Max number of threads to cap factor-based number to
|
# Max number of threads to cap factor-based number to
|
||||||
core-pool-size-max = 64
|
core-pool-size-max = 64
|
||||||
|
|
||||||
# Minimum number of threads to cap factor-based max number to (if using
|
# Minimum number of threads to cap factor-based max number to
|
||||||
# a bounded task queue)
|
# (if using a bounded task queue)
|
||||||
max-pool-size-min = 8
|
max-pool-size-min = 8
|
||||||
|
|
||||||
# Max no of threads (if using a bounded task queue) is determined by
|
# Max no of threads (if using a bounded task queue) is determined by
|
||||||
|
|
|
||||||
|
|
@ -8,8 +8,8 @@
|
||||||
akka {
|
akka {
|
||||||
|
|
||||||
cluster {
|
cluster {
|
||||||
# Initial contact points of the cluster. The nodes to join at startup if
|
# Initial contact points of the cluster.
|
||||||
# auto-join = on.
|
# The nodes to join at startup if auto-join = on.
|
||||||
# Comma separated full URIs defined by a string on the form of
|
# Comma separated full URIs defined by a string on the form of
|
||||||
# "akka://system@hostname:port"
|
# "akka://system@hostname:port"
|
||||||
# Leave as empty if the node should be a singleton cluster.
|
# Leave as empty if the node should be a singleton cluster.
|
||||||
|
|
|
||||||
|
|
@ -202,8 +202,8 @@ public class UntypedActorDocTestBase {
|
||||||
ActorRef actorRef = system.actorOf(new Props(MyUntypedActor.class));
|
ActorRef actorRef = system.actorOf(new Props(MyUntypedActor.class));
|
||||||
//#gracefulStop
|
//#gracefulStop
|
||||||
try {
|
try {
|
||||||
Future<Boolean> stopped = gracefulStop(actorRef,
|
Future<Boolean> stopped =
|
||||||
Duration.create(5, TimeUnit.SECONDS), system);
|
gracefulStop(actorRef, Duration.create(5, TimeUnit.SECONDS), system);
|
||||||
Await.result(stopped, Duration.create(6, TimeUnit.SECONDS));
|
Await.result(stopped, Duration.create(6, TimeUnit.SECONDS));
|
||||||
// the actor has been stopped
|
// the actor has been stopped
|
||||||
} catch (AskTimeoutException e) {
|
} catch (AskTimeoutException e) {
|
||||||
|
|
|
||||||
|
|
@ -6,8 +6,8 @@ public class HttpSample {
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
//#HttpExample
|
//#HttpExample
|
||||||
// Create the actors. this can be done in a Boot class so you can
|
// Create the actors. this can be done in a Boot class so you can
|
||||||
// run the example in the MicroKernel. just add the three lines to below
|
// run the example in the MicroKernel. Just add the three lines below
|
||||||
// your boot class.
|
// to your boot class.
|
||||||
ActorSystem system = ActorSystem.create("some-system");
|
ActorSystem system = ActorSystem.create("some-system");
|
||||||
final ActorRef httpTransformer = system.actorOf(new Props(HttpTransformer.class));
|
final ActorRef httpTransformer = system.actorOf(new Props(HttpTransformer.class));
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -39,8 +39,8 @@ object HttpExample {
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create the actors. this can be done in a Boot class so you can
|
// Create the actors. this can be done in a Boot class so you can
|
||||||
// run the example in the MicroKernel. just add the three lines below to
|
// run the example in the MicroKernel. Just add the three lines below
|
||||||
// your boot class.
|
// to your boot class.
|
||||||
val system = ActorSystem("some-system")
|
val system = ActorSystem("some-system")
|
||||||
val httpTransformer = system.actorOf(Props[HttpTransformer])
|
val httpTransformer = system.actorOf(Props[HttpTransformer])
|
||||||
val httpProducer = system.actorOf(Props(new HttpProducer(httpTransformer)))
|
val httpProducer = system.actorOf(Props(new HttpProducer(httpTransformer)))
|
||||||
|
|
|
||||||
|
|
@ -37,8 +37,8 @@ akka {
|
||||||
# maximum overflow (multiplier) of a journal file before we re-create it.
|
# maximum overflow (multiplier) of a journal file before we re-create it.
|
||||||
max-journal-overflow = 10
|
max-journal-overflow = 10
|
||||||
|
|
||||||
# absolute maximum size of a journal file until we rebuild it, no matter
|
# absolute maximum size of a journal file until we rebuild it,
|
||||||
# what.
|
# no matter what.
|
||||||
max-journal-size-absolute = 9223372036854775807 bytes
|
max-journal-size-absolute = 9223372036854775807 bytes
|
||||||
|
|
||||||
# whether to drop older items (instead of newer) when the queue is full
|
# whether to drop older items (instead of newer) when the queue is full
|
||||||
|
|
|
||||||
|
|
@ -67,12 +67,12 @@ akka {
|
||||||
# Timeout for ACK of cluster operations, like checking actor out etc.
|
# Timeout for ACK of cluster operations, like checking actor out etc.
|
||||||
remote-daemon-ack-timeout = 30s
|
remote-daemon-ack-timeout = 30s
|
||||||
|
|
||||||
# If this is "on", Akka will log all inbound messages at DEBUG level, if off
|
# If this is "on", Akka will log all inbound messages at DEBUG level,
|
||||||
# then they are not logged
|
# if off then they are not logged
|
||||||
log-received-messages = off
|
log-received-messages = off
|
||||||
|
|
||||||
# If this is "on", Akka will log all outbound messages at DEBUG level, if off
|
# If this is "on", Akka will log all outbound messages at DEBUG level,
|
||||||
# then they are not logged
|
# if off then they are not logged
|
||||||
log-sent-messages = off
|
log-sent-messages = off
|
||||||
|
|
||||||
# If this is "on", Akka will log all RemoteLifeCycleEvents at the level
|
# If this is "on", Akka will log all RemoteLifeCycleEvents at the level
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue