[ISSUE #5095] Add some remoting test

apache · Oct 9, 2022 · 2456c14 · 2456c14
1 parent 9f225ac
commit 2456c14
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/remoting/src/test/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstractTest.java b/remoting/src/test/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstractTest.java
@@ -110,12 +110,8 @@ public void operationComplete(final ResponseFuture responseFuture) {
     public void testProcessRequestCommand() throws InterruptedException {
         final Semaphore semaphore = new Semaphore(0);
         RemotingCommand request = RemotingCommand.createRequestCommand(1, null);
-        ResponseFuture responseFuture = new ResponseFuture(null, 1, request, 3000, new InvokeCallback() {
-            @Override
-            public void operationComplete(final ResponseFuture responseFuture) {
-                assertThat(semaphore.availablePermits()).isEqualTo(0);
-            }
-        }, new SemaphoreReleaseOnlyOnce(semaphore));
+        ResponseFuture responseFuture = new ResponseFuture(null, 1, request, 3000,
+            responseFuture1 -> assertThat(semaphore.availablePermits()).isEqualTo(0), new SemaphoreReleaseOnlyOnce(semaphore));
 
         remotingAbstract.responseTable.putIfAbsent(1, responseFuture);
         RemotingCommand response = RemotingCommand.createResponseCommand(0, "Foo");