@@ -281,18 +281,18 @@ public void testStaleReadAsync() throws Exception {
281281 }
282282
283283 void runTestStaleReadAsync (CLUSTER cluster ) throws Exception {
284- final int numMesssages = 10 ;
284+ final int numMessages = 10 ;
285285 try (RaftClient client = cluster .createClient ()) {
286286 RaftTestUtil .waitForLeader (cluster );
287287
288288 // submit some messages
289289 final List <CompletableFuture <RaftClientReply >> futures = new ArrayList <>();
290- for (int i = 0 ; i < numMesssages ; i ++) {
290+ for (int i = 0 ; i < numMessages ; i ++) {
291291 final String s = "" + i ;
292292 LOG .info ("sendAsync " + s );
293293 futures .add (client .async ().send (new SimpleMessage (s )));
294294 }
295- Assert .assertEquals (numMesssages , futures .size ());
295+ Assert .assertEquals (numMessages , futures .size ());
296296 final List <RaftClientReply > replies = new ArrayList <>();
297297 for (CompletableFuture <RaftClientReply > f : futures ) {
298298 final RaftClientReply r = f .join ();
@@ -322,7 +322,7 @@ void runTestStaleReadAsync(CLUSTER cluster) throws Exception {
322322 StateMachineException .class , IndexOutOfBoundsException .class );
323323
324324 // test sendStaleReadAsync
325- for (int i = 0 ; i < numMesssages ; i ++) {
325+ for (int i = 0 ; i < numMessages ; i ++) {
326326 final RaftClientReply reply = replies .get (i );
327327 final String query = "" + i ;
328328 LOG .info ("query=" + query + ", reply=" + reply );
0 commit comments