This is an automated email from the ASF dual-hosted git repository.

mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git


The following commit(s) were added to refs/heads/master by this push:
     new d976bbf63 [ISSUE #3826]'assertTrue()' can be simplified to 
'assertEquals()' (#3840)
d976bbf63 is described below

commit d976bbf635b7f4bcdc032b1af5da175b6246e4b3
Author: Harshitha Sudhakar 
<[email protected]>
AuthorDate: Fri May 5 18:19:02 2023 +0530

    [ISSUE #3826]'assertTrue()' can be simplified to 'assertEquals()' (#3840)
    
    * Update MessageQueueTest.java
    
    Replaced `assertTrue()` with `assertEquals` at lines 106,111
    
    * Update MessageQueueTest.java
    
    * Update MessageQueueTest.java
---
 .../apache/eventmesh/storage/standalone/broker/MessageQueueTest.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/MessageQueueTest.java
 
b/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/MessageQueueTest.java
index a5ddcf8b0..c6ef39a59 100644
--- 
a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/MessageQueueTest.java
+++ 
b/eventmesh-storage-plugin/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/MessageQueueTest.java
@@ -103,12 +103,12 @@ public class MessageQueueTest {
     public void testGetTakeIndex() throws InterruptedException {
         MessageEntity takeIndexMessageEntity = messageQueue.take();
         Assert.assertNotNull(takeIndexMessageEntity);
-        Assert.assertTrue(messageQueue.getTakeIndex() == 1);
+        Assert.assertEquals(1, messageQueue.getPutIndex());
     }
 
     @Test
     public void testGetPutIndex() {
-        Assert.assertTrue(messageQueue.getPutIndex() == 1);
+        Assert.assertEquals(1, messageQueue.getPutIndex());
     }
 
     private void initMessageQueue() throws InterruptedException {


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to