INT-8 added namespace support for Claim Check pattern

This commit is contained in:
Mark Fisher
2010-05-04 17:30:58 +00:00
parent a7afdd7be6
commit 0b41c9a670
6 changed files with 260 additions and 1 deletions

View File

@@ -0,0 +1,45 @@
/*
* Copyright 2002-2010 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.integration.config.xml;
import org.w3c.dom.Element;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.xml.ParserContext;
import org.springframework.util.Assert;
/**
* Parser for the <claim-check-in/> element.
*
* @author Mark Fisher
* @since 2.0
*/
public class ClaimCheckInParser extends AbstractTransformerParser {
@Override
protected String getTransformerClassName() {
return IntegrationNamespaceUtils.BASE_PACKAGE + ".transformer.ClaimCheckInTransformer";
}
@Override
protected void parseTransformer(Element element, ParserContext parserContext, BeanDefinitionBuilder builder) {
String messageStoreRef = element.getAttribute("message-store");
Assert.hasText(messageStoreRef, "The 'message-store' attribute is required.");
builder.addConstructorArgReference(messageStoreRef);
}
}

View File

@@ -0,0 +1,45 @@
/*
* Copyright 2002-2010 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.integration.config.xml;
import org.w3c.dom.Element;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.xml.ParserContext;
import org.springframework.util.Assert;
/**
* Parser for the <claim-check-out/> element.
*
* @author Mark Fisher
* @since 2.0
*/
public class ClaimCheckOutParser extends AbstractTransformerParser {
@Override
protected String getTransformerClassName() {
return IntegrationNamespaceUtils.BASE_PACKAGE + ".transformer.ClaimCheckOutTransformer";
}
@Override
protected void parseTransformer(Element element, ParserContext parserContext, BeanDefinitionBuilder builder) {
String messageStoreRef = element.getAttribute("message-store");
Assert.hasText(messageStoreRef, "The 'message-store' attribute is required.");
builder.addConstructorArgReference(messageStoreRef);
}
}

View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2009 the original author or authors.
* Copyright 2002-2010 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -43,6 +43,8 @@ public class IntegrationNamespaceHandler extends AbstractIntegrationNamespaceHan
registerBeanDefinitionParser("object-to-string-transformer", new ObjectToStringTransformerParser());
registerBeanDefinitionParser("payload-serializing-transformer", new PayloadSerializingTransformerParser());
registerBeanDefinitionParser("payload-deserializing-transformer", new PayloadDeserializingTransformerParser());
registerBeanDefinitionParser("claim-check-in", new ClaimCheckInParser());
registerBeanDefinitionParser("claim-check-out", new ClaimCheckOutParser());
registerBeanDefinitionParser("inbound-channel-adapter", new MethodInvokingInboundChannelAdapterParser());
registerBeanDefinitionParser("outbound-channel-adapter", new MethodInvokingOutboundChannelAdapterParser());
registerBeanDefinitionParser("logging-channel-adapter", new LoggingChannelAdapterParser());

View File

@@ -1308,6 +1308,46 @@
</xsd:complexType>
</xsd:element>
<xsd:element name="claim-check-in" type="claimCheckTransformerType">
<xsd:annotation>
<xsd:documentation>
Defines a Transformer that stores a Message and returns a new Message whose
payload is the id of the stored Message.
</xsd:documentation>
</xsd:annotation>
</xsd:element>
<xsd:element name="claim-check-out" type="claimCheckTransformerType">
<xsd:annotation>
<xsd:documentation>
Defines a Transformer that accepts a Message whose payload is a UUID and retrieves
the Message associated with that id from a MessageStore if available (else null).
</xsd:documentation>
</xsd:annotation>
</xsd:element>
<xsd:complexType name="claimCheckTransformerType">
<xsd:complexContent>
<xsd:extension base="inputOutputEndpointType">
<xsd:sequence minOccurs="0" maxOccurs="1">
<xsd:element ref="poller"/>
</xsd:sequence>
<xsd:attribute name="message-store" use="required">
<xsd:annotation>
<xsd:documentation>
Reference to the MessageStore to be used by this Claim Check transformer.
</xsd:documentation>
<xsd:appinfo>
<tool:annotation kind="ref">
<tool:expected-type type="org.springframework.integration.store.MessageStore"/>
</tool:annotation>
</xsd:appinfo>
</xsd:annotation>
</xsd:attribute>
</xsd:extension>
</xsd:complexContent>
</xsd:complexType>
<xsd:element name="payload-serializing-transformer">
<xsd:annotation>
<xsd:documentation>