Updated conf aswell
This commit is contained in:
parent
93cdf1faed
commit
1d694d7c67
2 changed files with 2 additions and 2 deletions
|
|
@ -102,7 +102,7 @@ class JGroupsClusterActor extends ClusterActor {
|
|||
@volatile private var remotes: Map[Address, Node] = Map()
|
||||
|
||||
override def init = {
|
||||
log error "Initiating cluster actor"
|
||||
log debug "Initiating cluster actor"
|
||||
remotes = new HashMap[Address, Node]
|
||||
val me = this
|
||||
//Set up the JGroups local endpoint
|
||||
|
|
|
|||
|
|
@ -38,7 +38,7 @@
|
|||
|
||||
<cluster>
|
||||
name = "default"
|
||||
actor = "se.scalablesolutions.akka.nio.JGroupsClusterActor"
|
||||
actor = "se.scalablesolutions.akka.remote.JGroupsClusterActor"
|
||||
</cluster>
|
||||
|
||||
<server>
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue