throughput = 1
}
+ serialization-dispatcher {
+ type = Dispatcher
+ executor = "fork-join-executor"
+ fork-join-executor {
+ # Min number of threads to cap factor-based parallelism number to
+ parallelism-min = 2
+ # Parallelism (threads) ... ceil(available processors * factor)
+ parallelism-factor = 2.0
+ # Max number of threads to cap factor-based parallelism number to
+ parallelism-max = 15
+ }
+ throughput = 1
+ }
+
shard-dispatcher {
type = Dispatcher
executor = "default-executor"
cluster {
seed-node-timeout = 12s
-
+
# Following is an excerpt from Akka Cluster Documentation
# link - http://doc.akka.io/docs/akka/snapshot/java/cluster-usage.html
# Warning - Akka recommends against using the auto-down feature of Akka Cluster in production.
- # This is crucial for correct behavior if you use Cluster Singleton or Cluster Sharding,
+ # This is crucial for correct behavior if you use Cluster Singleton or Cluster Sharding,
# especially together with Akka Persistence.
#auto-down-unreachable-after = 30s
public static final String TXN_DISPATCHER_PATH = "txn-dispatcher";
public static final String SHARD_DISPATCHER_PATH = "shard-dispatcher";
public static final String NOTIFICATION_DISPATCHER_PATH = "notification-dispatcher";
+ public static final String SERIALIZATION_DISPATCHER_PATH = "serialization-dispatcher";
private final akka.dispatch.Dispatchers dispatchers;
Client(CLIENT_DISPATCHER_PATH),
Transaction(TXN_DISPATCHER_PATH),
Shard(SHARD_DISPATCHER_PATH),
- Notification(NOTIFICATION_DISPATCHER_PATH);
+ Notification(NOTIFICATION_DISPATCHER_PATH),
+ Serialization(SERIALIZATION_DISPATCHER_PATH);
private final String path;
+
DispatcherType(String path) {
this.path = path;
}