29
29
import io .dapr .client .domain .TransactionalStateOperation ;
30
30
import io .dapr .client .domain .UnsubscribeConfigurationRequest ;
31
31
import io .dapr .client .domain .UnsubscribeConfigurationResponse ;
32
+ import io .dapr .exceptions .DaprError ;
33
+ import io .dapr .exceptions .DaprException ;
32
34
import io .dapr .serializer .DaprObjectSerializer ;
33
35
import io .dapr .serializer .DefaultObjectSerializer ;
34
36
import io .dapr .utils .TypeRef ;
@@ -2117,7 +2119,29 @@ public void getMetadataTest() {
2117
2119
assertEquals ("app" , metadata .getId ());
2118
2120
assertEquals ("1.1x.x" , metadata .getRuntimeVersion ());
2119
2121
assertEquals (1 , metadata .getComponents ().size ());
2122
+ assertEquals (registeredComponents .getName (), metadata .getComponents ().get (0 ).getName ());
2123
+ assertEquals (registeredComponents .getVersion (), metadata .getComponents ().get (0 ).getVersion ());
2124
+ assertEquals (registeredComponents .getType (), metadata .getComponents ().get (0 ).getType ());
2120
2125
assertEquals (1 , metadata .getSubscriptions ().size ());
2126
+ assertEquals (pubsubSubscription .getPubsubName (), metadata .getSubscriptions ().get (0 ).getPubsubname ());
2127
+ assertEquals (pubsubSubscription .getTopic (), metadata .getSubscriptions ().get (0 ).getTopic ());
2128
+ assertEquals (1 , metadata .getSubscriptions ().get (0 ).getRules ().size ());
2129
+ assertEquals (pubsubSubscription .getRules ().getRules (0 ).getPath (), metadata .getSubscriptions ().get (0 ).getRules ().get (0 ).getPath ());
2121
2130
2122
2131
}
2132
+
2133
+ @ Test
2134
+ public void getMetadataExceptionTest () {
2135
+ doAnswer ((Answer <Void >) invocation -> {
2136
+ throw new RuntimeException ();
2137
+ }).when (daprStub ).getMetadata (any (DaprProtos .GetMetadataRequest .class ), any ());
2138
+
2139
+ Mono <DaprMetadata > result = client .getMetadata ();
2140
+
2141
+ assertThrowsDaprException (
2142
+ RuntimeException .class ,
2143
+ "UNKNOWN" ,
2144
+ "UNKNOWN: " ,
2145
+ () -> result .block ());
2146
+ }
2123
2147
}
0 commit comments