*/
void receiveGetAllBuckets(){
final ActorRef sender = getSender();
- sender.tell(new GetAllBucketsReply<T>(getAllBuckets()), getSelf());
+ sender.tell(new GetAllBucketsReply<>(getAllBuckets()), getSelf());
}
/**
void receiveGetBucketsByMembers(Set<Address> members){
final ActorRef sender = getSender();
Map<Address, Bucket<T>> buckets = getBucketsByMembers(members);
- sender.tell(new GetBucketsByMembersReply<T>(buckets), getSelf());
+ sender.tell(new GetBucketsByMembersReply<>(buckets), getSelf());
}
/**
assertEquals("getType", TEST_RPC, routeIdentifier.getType());
assertEquals("getRoute", TEST_PATH, routeIdentifier.getRoute());
- rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<ActorRef, Long>(
+ rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<>(
rpcBroker2, 200L))));
final DOMRpcResult result = frontEndFuture.checkedGet(5, TimeUnit.SECONDS);
assertEquals("getType", TEST_RPC, routeIdentifier.getType());
assertEquals("getRoute", TEST_PATH, routeIdentifier.getRoute());
- rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<ActorRef, Long>(
+ rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<>(
rpcBroker2, 200L))));
final DOMRpcResult result = frontEndFuture.checkedGet(5, TimeUnit.SECONDS);
assertEquals("getType", TEST_RPC, routeIdentifier.getType());
assertEquals("getRoute", TEST_PATH, routeIdentifier.getRoute());
- rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<ActorRef, Long>(
+ rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<>(
rpcBroker2, 200L))));
final DOMRpcResult result = frontEndFuture.checkedGet(5, TimeUnit.SECONDS);
assertEquals("getType", TEST_RPC, routeIdentifier.getType());
assertEquals("getRoute", TEST_PATH, routeIdentifier.getRoute());
- rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<ActorRef, Long>(
+ rpcRegistry1Probe.reply(new RpcRegistry.Messages.FindRoutersReply(Arrays.asList(new Pair<>(
rpcBroker2, 200L))));
frontEndFuture.checkedGet(5, TimeUnit.SECONDS);
}
//Add a new remote bucket
Address a4 = new Address("tcp", "system4");
- Bucket<T> b4 = new BucketImpl<T>();
+ Bucket<T> b4 = new BucketImpl<>();
remoteBuckets.clear();
remoteBuckets.put(a4, b4);
store.receiveUpdateRemoteBuckets(remoteBuckets);
Assert.assertTrue(remoteBucketsInStore.size() == 4);
//Update a bucket
- Bucket<T> b3_new = new BucketImpl<T>();
+ Bucket<T> b3_new = new BucketImpl<>();
remoteBuckets.clear();
remoteBuckets.put(a3, b3_new);
remoteBuckets.put(a1, null);
ActorRef actor1 = probe1.ref();
ActorRef actor2 = probe2.ref();
ActorRef actor3 = probe3.ref();
- pairList.add(new Pair<ActorRef, Long>(actor1, 1000L));
- pairList.add(new Pair<ActorRef, Long>(actor2, 3000L));
- pairList.add(new Pair<ActorRef, Long>(actor3, 2000L));
+ pairList.add(new Pair<>(actor1, 1000L));
+ pairList.add(new Pair<>(actor2, 3000L));
+ pairList.add(new Pair<>(actor3, 2000L));
RoutingLogic logic = new LatestEntryRoutingLogic(pairList);
assertTrue(logic.select().equals(actor2));
}