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

ResequencerEndpoint is now Resequencer.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-07 01:59:56 +00:00
parent 0250529aa2
commit 080c19fb62
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/ResequencerEndpoint.java → org.springframework.integration/src/main/java/org/springframework/integration/aggregator/Resequencer.java
View File

@@ -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;

4
org.springframework.integration/src/main/java/org/springframework/integration/config/ResequencerParser.java
View File

@@ -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);

6
org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerEndpointTests.java → org.springframework.integration/src/test/java/org/springframework/integration/aggregator/ResequencerTests.java
View File

@@ -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();