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
index e1ca4f8bed6..8381c132b71 100644
--- 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");