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

INT-961

Browse Source
This commit is contained in:
Mark Fisher
2010-04-16 16:48:22 +00:00
parent 183cb2d464
commit 111f47ece9
4 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathMessageSplitterParserTests.java
View File

@@ -63,7 +63,7 @@ public class XPathMessageSplitterParserTests {
ctx.getAutowireCapableBeanFactory().autowireBeanProperties(this, AutowireCapableBeanFactory.AUTOWIRE_BY_TYPE,
false);
inputChannel.send(docMessage);
assertEquals("Wrong number of split messages ", 2, outputChannel.getMesssageCount());
assertEquals("Wrong number of split messages ", 2, outputChannel.getMessageCount());
}
@Test
@@ -78,7 +78,7 @@ public class XPathMessageSplitterParserTests {
ctx.getAutowireCapableBeanFactory().autowireBeanProperties(this, AutowireCapableBeanFactory.AUTOWIRE_BY_TYPE,
false);
inputChannel.send(docMessage);
assertEquals("Wrong number of split messages ", 2, outputChannel.getMesssageCount());
assertEquals("Wrong number of split messages ", 2, outputChannel.getMessageCount());
assertTrue("Splitter failed to create documents ",
((Message<?>) outputChannel.receive(1000)).getPayload() instanceof Document);
assertTrue("Splitter failed to create documents ",

10
org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathRouterParserTests.java
View File

@@ -77,7 +77,7 @@ public class XPathRouterParserTests {
GenericMessage<Document> docMessage = new GenericMessage<Document>(doc);
buildContext("<si-xml:xpath-router id='router' input-channel='test-input'><si-xml:xpath-expression expression='/name'/></si-xml:xpath-router>");
inputChannel.send(docMessage);
assertEquals("Wrong number of messages", 1, outputChannel.getMesssageCount());
assertEquals("Wrong number of messages", 1, outputChannel.getMessageCount());
}
@@ -87,7 +87,7 @@ public class XPathRouterParserTests {
GenericMessage<Document> docMessage = new GenericMessage<Document>(doc);
buildContext("<si-xml:xpath-router id='router' input-channel='test-input'><si-xml:xpath-expression expression='/ns2:name' ns-prefix='ns2' ns-uri='www.example.org' /></si-xml:xpath-router>");
inputChannel.send(docMessage);
assertEquals("Wrong number of messages", 1, outputChannel.getMesssageCount());
assertEquals("Wrong number of messages", 1, outputChannel.getMessageCount());
}
@@ -102,7 +102,7 @@ public class XPathRouterParserTests {
buffer.append("</si-xml:xpath-expression></si-xml:xpath-router>");
buildContext(buffer.toString());
inputChannel.send(docMessage);
assertEquals("Wrong number of messages", 1, outputChannel.getMesssageCount());
assertEquals("Wrong number of messages", 1, outputChannel.getMessageCount());
}
@@ -118,7 +118,7 @@ public class XPathRouterParserTests {
buildContext(buffer.toString());
inputChannel.send(docMessage);
assertEquals("Wrong number of messages", 1, outputChannel.getMesssageCount());
assertEquals("Wrong number of messages", 1, outputChannel.getMessageCount());
}
@Test
@@ -172,6 +172,6 @@ public class XPathRouterParserTests {
Object defaultOutputChannelValue = accessor.getPropertyValue("defaultOutputChannel");
assertEquals("Default output channel not correctly set ", defaultOutput, defaultOutputChannelValue);
inputChannel.send(MessageBuilder.withPayload("<unrelated/>").build());
assertEquals("Wrong count of messages on default output channel",1, defaultOutput.getMesssageCount());
assertEquals("Wrong count of messages on default output channel",1, defaultOutput.getMessageCount());
}
}

4
org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XmlPayloadValidatingRouterParserTests.java
View File

@@ -73,7 +73,7 @@ public class XmlPayloadValidatingRouterParserTests {
GenericMessage<Document> docMessage = new GenericMessage<Document>(doc);
buildContext("<si-xml:validating-router id='router' input-channel='test-input' valid-channel='validOutputChannel' invalid-channel='invalidOutputChannel' schema-location='org/springframework/integration/xml/config/validationTestsSchema.xsd' />");
inputChannel.send(docMessage);
assertEquals("Wrong number of messages", 1, validOutputChannel.getMesssageCount());
assertEquals("Wrong number of messages", 1, validOutputChannel.getMessageCount());
}
@Test
@@ -82,7 +82,7 @@ public class XmlPayloadValidatingRouterParserTests {
GenericMessage<Document> docMessage = new GenericMessage<Document>(doc);
buildContext("<si-xml:validating-router id='router' input-channel='test-input' valid-channel='validOutputChannel' invalid-channel='invalidOutputChannel' schema-location='org/springframework/integration/xml/config/validationTestsSchema.xsd' />");
inputChannel.send(docMessage);
assertEquals("Wrong number of messages", 1, invalidOutputChannel.getMesssageCount());
assertEquals("Wrong number of messages", 1, invalidOutputChannel.getMessageCount());
}

2
org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java
View File

@@ -122,7 +122,7 @@ public class QueueChannel extends AbstractPollableChannel {
return purgedMessages;
}
public int getMesssageCount(){
public int getMessageCount(){
return this.queue.size();
}