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

INT-1257, added convinience method MessageHistory.containsEntryWithName(string), added tests in XML to validate MessageHistory

Browse Source
This commit is contained in:
Oleg Zhurakousky
2010-09-21 13:49:46 -04:00
parent 19c705fcbc
commit f8b501e4f9
3 changed files with 20 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-xml/src/test/java/org/springframework/integration/xml/transformer/XsltTransformerTests-context.xml
View File

@@ -6,6 +6,8 @@
http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration-2.0.xsd
http://www.springframework.org/schema/integration/xml http://www.springframework.org/schema/integration/xml/spring-integration-xml-2.0.xsd">
<int:message-history/>
<int:channel id="output">
<int:queue />
</int:channel>

13
spring-integration-xml/src/test/java/org/springframework/integration/xml/transformer/XsltTransformerTests.java
View File

@@ -23,6 +23,7 @@ import org.springframework.context.ApplicationContext;
import org.springframework.integration.Message;
import org.springframework.integration.MessageChannel;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.history.MessageHistory;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@@ -54,7 +55,8 @@ public class XsltTransformerTests {
build();
input.send(message);
Message<?> resultMessage = output.receive();
System.out.println("Result: " + resultMessage);
MessageHistory history = MessageHistory.read(resultMessage);
assertTrue(history.containsEntryWithName("paramHeadersWithStartWildCharacter"));
assertEquals("Wrong payload type",String.class, resultMessage.getPayload().getClass());
assertTrue(((String) resultMessage.getPayload()).contains("testParamValue"));
assertFalse(((String) resultMessage.getPayload()).contains("FOO"));
@@ -68,7 +70,8 @@ public class XsltTransformerTests {
build();
input.send(message);
Message<?> resultMessage = output.receive();
System.out.println("Result: " + resultMessage);
MessageHistory history = MessageHistory.read(resultMessage);
assertTrue(history.containsEntryWithName("paramHeadersWithEndWildCharacter"));
assertEquals("Wrong payload type",String.class, resultMessage.getPayload().getClass());
assertTrue(((String) resultMessage.getPayload()).contains("testParamValue"));
assertTrue(((String) resultMessage.getPayload()).contains("FOO"));
@@ -82,7 +85,8 @@ public class XsltTransformerTests {
build();
input.send(message);
Message<?> resultMessage = output.receive();
System.out.println("Result: " + resultMessage);
MessageHistory history = MessageHistory.read(resultMessage);
assertTrue(history.containsEntryWithName("paramHeadersWithIndividualParameters"));
assertEquals("Wrong payload type",String.class, resultMessage.getPayload().getClass());
assertTrue(((String) resultMessage.getPayload()).contains("testParamValue"));
assertTrue(((String) resultMessage.getPayload()).contains("FOO"));
@@ -98,7 +102,8 @@ public class XsltTransformerTests {
build();
input.send(message);
Message<?> resultMessage = output.receive();
System.out.println("Result: " + resultMessage);
MessageHistory history = MessageHistory.read(resultMessage);
assertTrue(history.containsEntryWithName("paramHeadersComboChannel"));
assertEquals("Wrong payload type",String.class, resultMessage.getPayload().getClass());
assertTrue(((String) resultMessage.getPayload()).contains("testParamValue"));
assertTrue(((String) resultMessage.getPayload()).contains("FOO"));