+ private Address selfAddress = new Address("akka.tcp", "test", "127.0.0.1", 2550);
+ private String currentMemberName = "member-1";
+
+ public MockClusterWrapper() {
+ }
+
+ public MockClusterWrapper(String currentMemberName) {
+ this.currentMemberName = currentMemberName;
+ }
+
+ @Override
+ public void subscribeToMemberEvents(ActorRef actorRef) {
+ }
+
+ @Override
+ public String getCurrentMemberName() {
+ return currentMemberName;
+ }
+
+ @Override
+ public Address getSelfAddress() {
+ return selfAddress;