X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FClusterWrapperImpl.java;h=38d23f6884ca949e121579da0fb669391ffc058e;hp=56229132f34c3dec9a61ea1ea4377831f2af3274;hb=925cb4a228d0fda99c7bfeb432eb25285a223887;hpb=cab1d5845cb951fe31a3243653ed567583dc73c1 diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ClusterWrapperImpl.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ClusterWrapperImpl.java index 56229132f3..38d23f6884 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ClusterWrapperImpl.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ClusterWrapperImpl.java @@ -21,24 +21,23 @@ public class ClusterWrapperImpl implements ClusterWrapper { private final MemberName currentMemberName; private final Address selfAddress; - public ClusterWrapperImpl(ActorSystem actorSystem){ + public ClusterWrapperImpl(ActorSystem actorSystem) { Preconditions.checkNotNull(actorSystem, "actorSystem should not be null"); cluster = Cluster.get(actorSystem); Preconditions.checkState(cluster.getSelfRoles().size() > 0, - "No akka roles were specified\n" + - "One way to specify the member name is to pass a property on the command line like so\n" + - " -Dakka.cluster.roles.0=member-3\n" + - "member-3 here would be the name of the member" - ); + "No akka roles were specified.\n" + + "One way to specify the member name is to pass a property on the command line like so\n" + + " -Dakka.cluster.roles.0=member-3\n" + + "member-3 here would be the name of the member"); currentMemberName = MemberName.forName(cluster.getSelfRoles().iterator().next()); selfAddress = cluster.selfAddress(); } @Override - public void subscribeToMemberEvents(ActorRef actorRef){ + public void subscribeToMemberEvents(ActorRef actorRef) { Preconditions.checkNotNull(actorRef, "actorRef should not be null"); cluster.subscribe(actorRef, ClusterEvent.initialStateAsEvents(),