- private static ClusterEvent.MemberRemoved createMemberRemoved(String memberName, String address) {
- akka.cluster.UniqueAddress uniqueAddress = new UniqueAddress(
- AddressFromURIString.parse(address), 55);
-
- Set<String> roles = new HashSet<>();
-
- roles.add(memberName);
-
- akka.cluster.Member member = new akka.cluster.Member(uniqueAddress, 1, MemberStatus
- .removed(),
- JavaConversions.asScalaSet(roles).<String>toSet());
-
- return new ClusterEvent.MemberRemoved(member, MemberStatus.up());
+ public static MemberRemoved createMemberRemoved(final String memberName, final String address) {
+ UniqueAddress uniqueAddress = new UniqueAddress(AddressFromURIString.parse(address), 55L);
+ Member member = new Member(uniqueAddress, 1, MemberStatus.removed(), new Set1<>(memberName), Version.Zero());