opendaylight/md-sal/sal-distributed-datastore/src/test/resources/application-with-custom-dispatchers.conf

   1 akka {
   2     persistence.snapshot-store.plugin = "in-memory-snapshot-store"
   3     persistence.journal.plugin = "in-memory-journal"
   4
   5     loggers = ["akka.testkit.TestEventListener", "akka.event.slf4j.Slf4jLogger"]
   6
   7     actor {
   8          serializers {
   9                   java = "akka.serialization.JavaSerializer"
  10                   proto = "akka.remote.serialization.ProtobufSerializer"
  11          }
  12
  13         serialization-bindings {
  14             "org.opendaylight.controller.cluster.datastore.modification.MutableCompositeModification" = java
  15             "com.google.protobuf.Message" = proto
  16
  17         }
  18     }
  19 }
  20
  21 in-memory-journal {
  22     class = "org.opendaylight.controller.cluster.datastore.utils.InMemoryJournal"
  23 }
  24
  25 in-memory-snapshot-store {
  26   # Class name of the plugin.
  27   class = "org.opendaylight.controller.cluster.datastore.utils.InMemorySnapshotStore"
  28   # Dispatcher for the plugin actor.
  29   plugin-dispatcher = "akka.persistence.dispatchers.default-plugin-dispatcher"
  30 }
  31
  32 bounded-mailbox {
  33   mailbox-type = "org.opendaylight.controller.cluster.common.actor.MeteredBoundedMailbox"
  34   mailbox-capacity = 1000
  35   mailbox-push-timeout-time = 100ms
  36 }
  37
  38 client-dispatcher {
  39   # Dispatcher is the name of the event-based dispatcher
  40   type = Dispatcher
  41   # What kind of ExecutionService to use
  42   executor = "fork-join-executor"
  43   # Configuration for the fork join pool
  44   fork-join-executor {
  45     # Min number of threads to cap factor-based parallelism number to
  46     parallelism-min = 2
  47     # Parallelism (threads) ... ceil(available processors * factor)
  48     parallelism-factor = 2.0
  49     # Max number of threads to cap factor-based parallelism number to
  50     parallelism-max = 10
  51   }
  52   # Throughput defines the maximum number of messages to be
  53   # processed per actor before the thread jumps to the next actor.
  54   # Set to 1 for as fair as possible.
  55   throughput = 100
  56 }
  57
  58 transaction-dispatcher {
  59   # Dispatcher is the name of the event-based dispatcher
  60   type = Dispatcher
  61   # What kind of ExecutionService to use
  62   executor = "fork-join-executor"
  63   # Configuration for the fork join pool
  64   fork-join-executor {
  65     # Min number of threads to cap factor-based parallelism number to
  66     parallelism-min = 2
  67     # Parallelism (threads) ... ceil(available processors * factor)
  68     parallelism-factor = 2.0
  69     # Max number of threads to cap factor-based parallelism number to
  70     parallelism-max = 10
  71   }
  72   # Throughput defines the maximum number of messages to be
  73   # processed per actor before the thread jumps to the next actor.
  74   # Set to 1 for as fair as possible.
  75   throughput = 100
  76 }
  77
  78 shard-dispatcher {
  79   # Dispatcher is the name of the event-based dispatcher
  80   type = Dispatcher
  81   # What kind of ExecutionService to use
  82   executor = "fork-join-executor"
  83   # Configuration for the fork join pool
  84   fork-join-executor {
  85     # Min number of threads to cap factor-based parallelism number to
  86     parallelism-min = 2
  87     # Parallelism (threads) ... ceil(available processors * factor)
  88     parallelism-factor = 2.0
  89     # Max number of threads to cap factor-based parallelism number to
  90     parallelism-max = 10
  91   }
  92   # Throughput defines the maximum number of messages to be
  93   # processed per actor before the thread jumps to the next actor.
  94   # Set to 1 for as fair as possible.
  95   throughput = 100
  96 }
  97
  98 notification-dispatcher {
  99   # Dispatcher is the name of the event-based dispatcher
 100   type = Dispatcher
 101   # What kind of ExecutionService to use
 102   executor = "fork-join-executor"
 103   # Configuration for the fork join pool
 104   fork-join-executor {
 105     # Min number of threads to cap factor-based parallelism number to
 106     parallelism-min = 2
 107     # Parallelism (threads) ... ceil(available processors * factor)
 108     parallelism-factor = 2.0
 109     # Max number of threads to cap factor-based parallelism number to
 110     parallelism-max = 10
 111   }
 112   # Throughput defines the maximum number of messages to be
 113   # processed per actor before the thread jumps to the next actor.
 114   # Set to 1 for as fair as possible.
 115   throughput = 100
 116 }