support sofa registry kubernetes

sofastack · Feb 18, 2024 · a6430db · a6430db
1 parent e574c53
commit a6430db
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...ernetes/src/test/java/com/alipay/sofa/rpc/registry/kubernetes/KubernetesRegistryTest.java b/...ernetes/src/test/java/com/alipay/sofa/rpc/registry/kubernetes/KubernetesRegistryTest.java
@@ -213,6 +213,7 @@ public void testAll() throws InterruptedException {
         latch.await(5000, TimeUnit.MILLISECONDS);
         Map<String, ProviderGroup> ps = providerInfoListener.getData();
 
+        Assert.assertEquals(1, kubernetesRegistry.getConsumerListeners().size());
         Assert.assertTrue(ps.size() > 0);
         Assert.assertEquals(1, ps.size());
         Assert.assertNotNull(ps.get(RpcConstants.ADDRESS_DEFAULT_GROUP));