diff --git a/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/MqttAdapterTests.java b/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/MqttAdapterTests.java
index 0f25bf2f07..dc5b455cae 100644
--- a/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/MqttAdapterTests.java
+++ b/spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/MqttAdapterTests.java
@@ -332,7 +332,7 @@ public class MqttAdapterTests {
 
 		ErrorMessage errorMessage = (ErrorMessage) errorChannel.receive(0);
 		assertThat(errorMessage).isNotNull()
-				.extracting(Message::getPayload)
+				.extracting(ErrorMessage::getPayload)
 				.isInstanceOf(IllegalStateException.class);
 		IllegalStateException exception = (IllegalStateException) errorMessage.getPayload();
 		assertThat(exception).hasMessage("'MqttMessageConverter' returned 'null'");