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);
}