+ @Test
+ public void testAddShardReplicaFailures() throws Exception {
+ String name = "testAddShardReplicaFailures";
+ MemberNode memberNode = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name).
+ moduleShardsConfig("module-shards-cars-member-1.conf").build();
+
+ ClusterAdminRpcService service = new ClusterAdminRpcService(memberNode.configDataStore(),
+ memberNode.operDataStore());
+
+ RpcResult<Void> rpcResult = service.addShardReplica(new AddShardReplicaInputBuilder().
+ setDataStoreType(DataStoreType.Config).build()).get(10, TimeUnit.SECONDS);
+ verifyFailedRpcResult(rpcResult);
+
+ rpcResult = service.addShardReplica(new AddShardReplicaInputBuilder().setShardName("cars").
+ build()).get(10, TimeUnit.SECONDS);
+ verifyFailedRpcResult(rpcResult);
+
+ rpcResult = service.addShardReplica(new AddShardReplicaInputBuilder().setShardName("people").
+ setDataStoreType(DataStoreType.Config).build()).get(10, TimeUnit.SECONDS);
+ verifyFailedRpcResult(rpcResult);
+
+ service.close();
+ }
+