Added receive call to propagation test to avoid collision with the expected results of other methods.

This commit is contained in:
Mark Fisher
2008-10-09 20:56:08 +00:00
parent b7e4aee3ae
commit 3b28f09c7c

View File

@@ -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());
}