Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added tests for a MessageFilter that delegates to a MessageSelector implementation (instead of the MethodInvokingSelector).

Browse Source
This commit is contained in:
Mark Fisher
2008-10-07 20:48:44 +00:00
parent 9b041646eb
commit ea220cac6c
2 changed files with 57 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
org.springframework.integration/src/test/java/org/springframework/integration/config/FilterParserTests-context.xml
View File

@@ -9,13 +9,22 @@
<message-bus/>
<channel id="output">
<channel id="adapterOutput">
<queue capacity="1"/>
</channel>
<filter ref="selector" method="hasText" input-channel="input" output-channel="output"/>
<channel id="implementationOutput">
<queue capacity="1"/>
</channel>
<beans:bean id="selector"
class="org.springframework.integration.config.FilterParserTests$TestSelector"/>
<filter ref="selectorBean" method="hasText" input-channel="adapterInput" output-channel="adapterOutput"/>
<beans:bean id="selectorBean"
class="org.springframework.integration.config.FilterParserTests$TestSelectorBean"/>
<filter ref="selectorImpl" input-channel="implementationInput" output-channel="implementationOutput"/>
<beans:bean id="selectorImpl"
class="org.springframework.integration.config.FilterParserTests$TestSelectorImpl"/>
</beans:beans>

55
org.springframework.integration/src/test/java/org/springframework/integration/config/FilterParserTests.java
View File

@@ -29,6 +29,7 @@ import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.channel.PollableChannel;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.StringMessage;
import org.springframework.integration.message.selector.MessageSelector;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.util.StringUtils;
@@ -40,34 +41,66 @@ import org.springframework.util.StringUtils;
@ContextConfiguration
public class FilterParserTests {
@Autowired @Qualifier("input")
MessageChannel input;
@Autowired @Qualifier("adapterInput")
MessageChannel adapterInput;
@Autowired @Qualifier("output")
PollableChannel output;
@Autowired @Qualifier("adapterOutput")
PollableChannel adapterOutput;
@Autowired @Qualifier("implementationInput")
MessageChannel implementationInput;
@Autowired @Qualifier("implementationOutput")
PollableChannel implementationOutput;
@Test
public void filterAccepts() {
input.send(new StringMessage("test"));
Message<?> reply = output.receive(0);
public void filterWithSelectorAdapterAccepts() {
adapterInput.send(new StringMessage("test"));
Message<?> reply = adapterOutput.receive(0);
assertNotNull(reply);
assertEquals("test", reply.getPayload());
}
@Test
public void filterRejects() {
input.send(new StringMessage(""));
Message<?> reply = output.receive(0);
public void filterWithSelectorAdapterRejects() {
adapterInput.send(new StringMessage(""));
Message<?> reply = adapterOutput.receive(0);
assertNull(reply);
}
@Test
public void filterWithSelectorImplementationAccepts() {
implementationInput.send(new StringMessage("test"));
Message<?> reply = implementationOutput.receive(0);
assertNotNull(reply);
assertEquals("test", reply.getPayload());
}
@Test
public void filterWithSelectorImplementationRejects() {
implementationInput.send(new StringMessage(""));
Message<?> reply = implementationOutput.receive(0);
assertNull(reply);
}
public static class TestSelector {
public static class TestSelectorBean {
public boolean hasText(String s) {
return StringUtils.hasText(s);
}
}
public static class TestSelectorImpl implements MessageSelector {
public boolean accept(Message<?> message) {
if (message != null && message.getPayload() instanceof String) {
return StringUtils.hasText((String) message.getPayload());
}
return false;
}
}
}