File tree 1 file changed +2
-0
lines changed
pulsar-proxy/src/test/java/org/apache/pulsar/proxy/server
1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change 25
25
import static org .testng .Assert .assertEquals ;
26
26
import static org .testng .Assert .assertNotNull ;
27
27
import static org .testng .Assert .assertTrue ;
28
+ import static org .testng .Assert .fail ;
28
29
import io .netty .buffer .ByteBuf ;
29
30
import io .netty .channel .EventLoopGroup ;
30
31
import io .netty .util .concurrent .DefaultThreadFactory ;
@@ -446,6 +447,7 @@ public void testGetPartitionedMetadataErrorCode() throws Exception {
446
447
assertEquals (proxyMetadata .partitions , 1 );
447
448
try {
448
449
proxyClient .getPartitionedTopicMetadata (topic + "-partition-0" , false , false ).get ();
450
+ fail ("expected a TopicDoesNotExistException" );
449
451
} catch (Exception ex ) {
450
452
assertTrue (FutureUtil .unwrapCompletionException (ex )
451
453
instanceof PulsarClientException .TopicDoesNotExistException );
You can’t perform that action at this time.
0 commit comments