From 080c19fb62c2d53fd4df6cad46e5a6af82c67818 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Tue, 7 Oct 2008 01:59:56 +0000 Subject: [PATCH] ResequencerEndpoint is now Resequencer. --- .../{ResequencerEndpoint.java => Resequencer.java} | 2 +- .../integration/config/ResequencerParser.java | 4 ++-- ...{ResequencerEndpointTests.java => ResequencerTests.java} | 6 +++--- 3 files changed, 6 insertions(+), 6 deletions(-) rename org.springframework.integration/src/main/java/org/springframework/integration/aggregator/{ResequencerEndpoint.java => Resequencer.java} (96%) rename org.springframework.integration/src/test/java/org/springframework/integration/aggregator/{ResequencerEndpointTests.java => ResequencerTests.java} (97%) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/ResequencerEndpoint.java b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java similarity index 96% rename from org.springframework.integration/src/main/java/org/springframework/integration/aggregator/ResequencerEndpoint.java rename to org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java index de3f0e1304..426085d10b 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/ResequencerEndpoint.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java @@ -35,7 +35,7 @@ import org.springframework.integration.message.MessageHeaders; * * @author Marius Bogoevici */ -public class ResequencerEndpoint extends AbstractMessageBarrierEndpoint { +public class Resequencer extends AbstractMessageBarrierEndpoint { private volatile boolean releasePartialSequences = true; diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/ResequencerParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/ResequencerParser.java index 45a9764fa5..000bdd5e75 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/ResequencerParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/ResequencerParser.java @@ -20,7 +20,7 @@ import org.w3c.dom.Element; import org.springframework.beans.factory.support.BeanDefinitionBuilder; import org.springframework.beans.factory.xml.ParserContext; -import org.springframework.integration.aggregator.ResequencerEndpoint; +import org.springframework.integration.aggregator.Resequencer; /** * Parser for the <resequencer> element. @@ -46,7 +46,7 @@ public class ResequencerParser extends AbstractEndpointParser { @Override protected BeanDefinitionBuilder parseConsumer(Element element, ParserContext parserContext) { - BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(ResequencerEndpoint.class); + BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(Resequencer.class); IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, DISCARD_CHANNEL_ATTRIBUTE); IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, SEND_TIMEOUT_ATTRIBUTE); IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, RELEASE_PARTIAL_SEQUENCES); diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerEndpointTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerTests.java similarity index 97% rename from org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerEndpointTests.java rename to org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerTests.java index 624d1e07ac..10f587cc30 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerEndpointTests.java +++ b/org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerTests.java @@ -33,16 +33,16 @@ import org.springframework.integration.scheduling.TaskScheduler; /** * @author Marius Bogoevici */ -public class ResequencerEndpointTests { +public class ResequencerTests { - private ResequencerEndpoint resequencer; + private Resequencer resequencer; private TaskScheduler taskScheduler; @Before public void configureResequencer() { - this.resequencer = new ResequencerEndpoint(); + this.resequencer = new Resequencer(); this.taskScheduler = Schedulers.createDefaultTaskScheduler(10); this.resequencer.setTaskScheduler(taskScheduler); taskScheduler.start();