From b39865606a78925b89a7f7cd645f5246694b3f4d Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Tue, 1 Jul 2008 23:31:33 +0000 Subject: [PATCH] Added calls to sourceEndpoint.afterPropertiesSet() in tests. --- .../integration/adapter/stream/ByteStreamSourceTests.java | 3 +++ .../integration/adapter/stream/CharacterStreamSourceTests.java | 1 + 2 files changed, 4 insertions(+) diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceTests.java b/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceTests.java index 34f948ddc8..e6e33a2dae 100644 --- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceTests.java +++ b/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/ByteStreamSourceTests.java @@ -43,6 +43,7 @@ public class ByteStreamSourceTests { MessageChannel channel = new QueueChannel(); ByteStreamSource source = new ByteStreamSource(stream); SourceEndpoint endpoint = new SourceEndpoint(source, channel); + endpoint.afterPropertiesSet(); endpoint.invoke(new CommandMessage(new PollCommand())); Message message1 = channel.receive(500); byte[] payload = (byte[]) message1.getPayload(); @@ -67,6 +68,7 @@ public class ByteStreamSourceTests { PollingSchedule schedule = new PollingSchedule(1000); schedule.setInitialDelay(10000); SourceEndpoint endpoint = new SourceEndpoint(source, channel); + endpoint.afterPropertiesSet(); endpoint.invoke(new CommandMessage(new PollCommand())); Message message1 = channel.receive(0); assertEquals(4, ((byte[]) message1.getPayload()).length); @@ -88,6 +90,7 @@ public class ByteStreamSourceTests { PollingSchedule schedule = new PollingSchedule(1000); schedule.setInitialDelay(10000); SourceEndpoint endpoint = new SourceEndpoint(source, channel); + endpoint.afterPropertiesSet(); endpoint.invoke(new CommandMessage(new PollCommand())); Message message1 = channel.receive(0); assertEquals(4, ((byte[]) message1.getPayload()).length); diff --git a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceTests.java b/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceTests.java index 3593ebfe8d..09ee9e60b5 100644 --- a/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceTests.java +++ b/org.springframework.integration.adapter/src/test/java/org/springframework/integration/adapter/stream/CharacterStreamSourceTests.java @@ -44,6 +44,7 @@ public class CharacterStreamSourceTests { PollingSchedule schedule = new PollingSchedule(1000); schedule.setInitialDelay(10000); SourceEndpoint endpoint = new SourceEndpoint(source, channel); + endpoint.afterPropertiesSet(); endpoint.invoke(new CommandMessage(new PollCommand())); Message message1 = channel.receive(0); assertEquals("test", message1.getPayload());