From 111f47ece913fd2419bab85669c6070e5f8abeed Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Fri, 16 Apr 2010 16:48:22 +0000 Subject: [PATCH] INT-961 --- .../xml/config/XPathMessageSplitterParserTests.java | 4 ++-- .../integration/xml/config/XPathRouterParserTests.java | 10 +++++----- .../config/XmlPayloadValidatingRouterParserTests.java | 4 ++-- .../integration/channel/QueueChannel.java | 2 +- 4 files changed, 10 insertions(+), 10 deletions(-) diff --git a/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathMessageSplitterParserTests.java b/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathMessageSplitterParserTests.java index 9b79215411..e18b358847 100644 --- a/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathMessageSplitterParserTests.java +++ b/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathMessageSplitterParserTests.java @@ -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 ", diff --git a/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathRouterParserTests.java b/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathRouterParserTests.java index b1b21890f0..076467f3e4 100644 --- a/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathRouterParserTests.java +++ b/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XPathRouterParserTests.java @@ -77,7 +77,7 @@ public class XPathRouterParserTests { GenericMessage docMessage = new GenericMessage(doc); buildContext(""); 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 docMessage = new GenericMessage(doc); buildContext(""); 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(""); 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("").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()); } } diff --git a/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XmlPayloadValidatingRouterParserTests.java b/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XmlPayloadValidatingRouterParserTests.java index f0fc650277..9088fe8528 100644 --- a/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XmlPayloadValidatingRouterParserTests.java +++ b/org.springframework.integration.xml/src/test/java/org/springframework/integration/xml/config/XmlPayloadValidatingRouterParserTests.java @@ -73,7 +73,7 @@ public class XmlPayloadValidatingRouterParserTests { GenericMessage docMessage = new GenericMessage(doc); buildContext(""); 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 docMessage = new GenericMessage(doc); buildContext(""); inputChannel.send(docMessage); - assertEquals("Wrong number of messages", 1, invalidOutputChannel.getMesssageCount()); + assertEquals("Wrong number of messages", 1, invalidOutputChannel.getMessageCount()); } diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java b/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java index 3869e3ef62..172ab5bc5e 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/channel/QueueChannel.java @@ -122,7 +122,7 @@ public class QueueChannel extends AbstractPollableChannel { return purgedMessages; } - public int getMesssageCount(){ + public int getMessageCount(){ return this.queue.size(); }