Replace assertTrue to assertEquals (apache#16518)

bestming8 · Jul 13, 2022 · 8002756 · 8002756
1 parent 553f341
commit 8002756
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorTest.java
@@ -133,25 +133,25 @@ public void testConnectionCreation() throws PulsarClientException {
         pulsarClient.newProducer(Schema.BOOL).topic("test").create();
         pulsarClient.newConsumer(Schema.STRING).topic("test1").subscriptionName("test-sub").subscribe();
         // single connection for both producer and consumer
-        Assert.assertTrue(((CounterBrokerInterceptor)listener).getConnectionCreationCount() == 1);
+        assertEquals(((CounterBrokerInterceptor) listener).getConnectionCreationCount(), 1);
     }
 
     @Test
     public void testProducerCreation() throws PulsarClientException {
         BrokerInterceptor listener = pulsar.getBrokerInterceptor();
         Assert.assertTrue(listener instanceof CounterBrokerInterceptor);
-        Assert.assertTrue(((CounterBrokerInterceptor)listener).getProducerCount() == 0);
+        assertEquals(((CounterBrokerInterceptor) listener).getProducerCount(), 0);
         pulsarClient.newProducer(Schema.BOOL).topic("test").create();
-        Assert.assertTrue(((CounterBrokerInterceptor)listener).getProducerCount() == 1);
+        assertEquals(((CounterBrokerInterceptor) listener).getProducerCount(), 1);
     }
 
     @Test
     public void testConsumerCreation() throws PulsarClientException {
         BrokerInterceptor listener = pulsar.getBrokerInterceptor();
         Assert.assertTrue(listener instanceof CounterBrokerInterceptor);
-        Assert.assertTrue(((CounterBrokerInterceptor)listener).getConsumerCount() == 0);
+        assertEquals(((CounterBrokerInterceptor) listener).getConsumerCount(), 0);
         pulsarClient.newConsumer(Schema.STRING).topic("test1").subscriptionName("test-sub").subscribe();
-        Assert.assertTrue(((CounterBrokerInterceptor)listener).getConsumerCount() == 1);
+        assertEquals(((CounterBrokerInterceptor) listener).getConsumerCount(), 1);
     }
 
     @Test