@@ -351,7 +351,7 @@ public void testSendMessageThatIsNotExpiredUsingAbsoluteTime() throws Exception
351351
352352 @ Test
353353 @ Timeout (60 )
354- public void testSendMessageThatIsExiredUsingAbsoluteTimeWithLongTTL () throws Exception {
354+ public void testSendMessageThatIsExpiredUsingAbsoluteTimeWithLongTTL () throws Exception {
355355 AmqpClient client = createAmqpClient ();
356356 AmqpConnection connection = addConnection (client .connect ());
357357 AmqpSession session = connection .createSession ();
@@ -419,7 +419,7 @@ public void testSendMessageThatIsExpiredUsingTTLWhenAbsoluteIsZero() throws Exce
419419
420420 @ Test
421421 @ Timeout (60 )
422- public void testSendMessageThatIsNotExpiredUsingAbsoluteTimeWithElspsedTTL () throws Exception {
422+ public void testSendMessageThatIsNotExpiredUsingAbsoluteTimeWithElapsedTTL () throws Exception {
423423 AmqpClient client = createAmqpClient ();
424424 AmqpConnection connection = addConnection (client .connect ());
425425 AmqpSession session = connection .createSession ();
@@ -596,7 +596,7 @@ public void internalSendExpiry(boolean restartServer) throws Throwable {
596596 sender .send (message );
597597
598598 Queue dlq = getProxyToQueue (getDeadLetterAddress ());
599- assertTrue (Wait .waitFor (() -> dlq .getMessageCount () > 0 , 7000 , 500 ), "Message not movied to DLQ" );
599+ assertTrue (Wait .waitFor (() -> dlq .getMessageCount () > 0 , 7000 , 500 ), "Message not moved to DLQ" );
600600
601601 connection .close ();
602602
@@ -654,7 +654,7 @@ public void testExpirationAfterDivert() throws Throwable {
654654 logger .debug ("*******************************************************************************************************************************" );
655655
656656 Queue forward = getProxyToQueue (FORWARDING_ADDRESS );
657- assertTrue (Wait .waitFor (() -> forward .getMessageCount () > 0 , 7000 , 500 ), "Message not diverted" );
657+ assertTrue (Wait .waitFor (() -> forward .getMessagesAdded () > 0 , 7000 , 500 ), "Message not diverted" );
658658
659659 Queue dlq = getProxyToQueue (getDeadLetterAddress ());
660660 assertTrue (Wait .waitFor (() -> dlq .getMessageCount () > 0 , 7000 , 500 ), "Message not moved to DLQ" );
@@ -708,7 +708,7 @@ public void testDLQdMessageCanBeRedeliveredMultipleTimes() throws Throwable {
708708 sender .send (message );
709709
710710 Queue dlqView = getProxyToQueue (getDeadLetterAddress ());
711- assertTrue (Wait .waitFor (() -> dlqView .getMessageCount () > 0 , 7000 , 200 ), "Message not movied to DLQ" );
711+ assertTrue (Wait .waitFor (() -> dlqView .getMessageCount () > 0 , 7000 , 200 ), "Message not moved to DLQ" );
712712
713713 // Read and Modify the message for redelivery repeatedly
714714 AmqpReceiver receiver = session .createReceiver (getDeadLetterAddress ());
@@ -742,17 +742,17 @@ public void testDLQdMessageCanBeRedeliveredMultipleTimes() throws Throwable {
742742
743743 @ Test
744744 @ Timeout (60 )
745- public void testExpireThorughAddressSettings () throws Exception {
746- testExpireThorughAddressSettings (false );
745+ public void testExpireThroughAddressSettings () throws Exception {
746+ testExpireThroughAddressSettings (false );
747747 }
748748
749749 @ Test
750750 @ Timeout (60 )
751- public void testExpireThorughAddressSettingsRebootServer () throws Exception {
752- testExpireThorughAddressSettings (true );
751+ public void testExpireThroughAddressSettingsRebootServer () throws Exception {
752+ testExpireThroughAddressSettings (true );
753753 }
754754
755- private void testExpireThorughAddressSettings (boolean reboot ) throws Exception {
755+ private void testExpireThroughAddressSettings (boolean reboot ) throws Exception {
756756
757757 // Address configuration
758758 AddressSettings addressSettings = new AddressSettings ();
0 commit comments