Merge pull request #1941 from ifplusor/fixed-typo-in-RequestResponseFuture

Fixed typo in RequestResponseFuture.

client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java

@@ -1356,12 +1356,12 @@ public class DefaultMQProducerImpl implements MQProducerInner {
             this.sendDefaultImpl(msg, CommunicationMode.ASYNC, new SendCallback() {
                 @Override
                 public void onSuccess(SendResult sendResult) {
-                    requestResponseFuture.setSendReqeustOk(true);
+                    requestResponseFuture.setSendRequestOk(true);
                 }
 
                 @Override
                 public void onException(Throwable e) {
-                    requestResponseFuture.setSendReqeustOk(false);
+                    requestResponseFuture.setSendRequestOk(false);
                     requestResponseFuture.putResponseMessage(null);
                     requestResponseFuture.setCause(e);
                 }
@@ -1386,7 +1386,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
         this.sendDefaultImpl(msg, CommunicationMode.ASYNC, new SendCallback() {
             @Override
             public void onSuccess(SendResult sendResult) {
-                requestResponseFuture.setSendReqeustOk(true);
+                requestResponseFuture.setSendRequestOk(true);
             }
 
             @Override
@@ -1412,12 +1412,12 @@ public class DefaultMQProducerImpl implements MQProducerInner {
             this.sendSelectImpl(msg, selector, arg, CommunicationMode.ASYNC, new SendCallback() {
                 @Override
                 public void onSuccess(SendResult sendResult) {
-                    requestResponseFuture.setSendReqeustOk(true);
+                    requestResponseFuture.setSendRequestOk(true);
                 }
 
                 @Override
                 public void onException(Throwable e) {
-                    requestResponseFuture.setSendReqeustOk(false);
+                    requestResponseFuture.setSendRequestOk(false);
                     requestResponseFuture.putResponseMessage(null);
                     requestResponseFuture.setCause(e);
                 }
@@ -1443,7 +1443,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
         this.sendSelectImpl(msg, selector, arg, CommunicationMode.ASYNC, new SendCallback() {
             @Override
             public void onSuccess(SendResult sendResult) {
-                requestResponseFuture.setSendReqeustOk(true);
+                requestResponseFuture.setSendRequestOk(true);
             }
 
             @Override
@@ -1469,12 +1469,12 @@ public class DefaultMQProducerImpl implements MQProducerInner {
             this.sendKernelImpl(msg, mq, CommunicationMode.ASYNC, new SendCallback() {
                 @Override
                 public void onSuccess(SendResult sendResult) {
-                    requestResponseFuture.setSendReqeustOk(true);
+                    requestResponseFuture.setSendRequestOk(true);
                 }
 
                 @Override
                 public void onException(Throwable e) {
-                    requestResponseFuture.setSendReqeustOk(false);
+                    requestResponseFuture.setSendRequestOk(false);
                     requestResponseFuture.putResponseMessage(null);
                     requestResponseFuture.setCause(e);
                 }
@@ -1512,7 +1512,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
         this.sendKernelImpl(msg, mq, CommunicationMode.ASYNC, new SendCallback() {
             @Override
             public void onSuccess(SendResult sendResult) {
-                requestResponseFuture.setSendReqeustOk(true);
+                requestResponseFuture.setSendRequestOk(true);
             }
 
             @Override
@@ -1526,7 +1526,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
     private void requestFail(final String correlationId) {
         RequestResponseFuture responseFuture = RequestFutureTable.getRequestFutureTable().remove(correlationId);
         if (responseFuture != null) {
-            responseFuture.setSendReqeustOk(false);
+            responseFuture.setSendRequestOk(false);
             responseFuture.putResponseMessage(null);
             try {
                 responseFuture.executeRequestCallback();

client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java

@@ -103,8 +103,8 @@ public class RequestResponseFuture {
         return sendRequestOk;
     }
 
-    public void setSendReqeustOk(boolean sendReqeustOk) {
-        this.sendRequestOk = sendReqeustOk;
+    public void setSendRequestOk(boolean sendRequestOk) {
+        this.sendRequestOk = sendRequestOk;
     }
 
     public Message getRequestMsg() {

client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java

@@ -373,7 +373,7 @@ public class DefaultMQProducerTest {
         assertThat(responseMap).isNotNull();
         for (Map.Entry<String, RequestResponseFuture> entry : responseMap.entrySet()) {
             RequestResponseFuture future = entry.getValue();
-            future.setSendReqeustOk(true);
+            future.setSendRequestOk(true);
             message.setFlag(1);
             future.getRequestCallback().onSuccess(message);
         }

client/src/test/java/org/apache/rocketmq/client/producer/RequestResponseFutureTest.java

@@ -37,7 +37,7 @@ public class RequestResponseFutureTest {
             @Override public void onException(Throwable e) {
             }
         });
-        future.setSendReqeustOk(true);
+        future.setSendRequestOk(true);
         future.executeRequestCallback();
         assertThat(cc.get()).isEqualTo(1);
     }