diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/config/PollerAnnotationChannelAdapterTransactionalTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/config/PollerAnnotationChannelAdapterTransactionalTests.java
index 6b07bc16a2..3cbeace163 100644
--- a/org.springframework.integration/src/test/java/org/springframework/integration/config/PollerAnnotationChannelAdapterTransactionalTests.java
+++ b/org.springframework.integration/src/test/java/org/springframework/integration/config/PollerAnnotationChannelAdapterTransactionalTests.java
@@ -78,8 +78,11 @@ public class PollerAnnotationChannelAdapterTransactionalTests {
 
 	@Test
 	public void verifyPropagationSetting() throws InterruptedException {
+		adapter.setShouldFail(false);
 		adapter.setNextValue("propagation-test");
 		transactionManager.waitForCompletion(1000);
+		Message<?> reply = output.receive(1000);
+		assertEquals("propagation-test", reply.getPayload());
 		assertEquals(TransactionDefinition.PROPAGATION_REQUIRES_NEW,
 				transactionManager.getLastDefinition().getPropagationBehavior());
 	}