diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractHeaderTransformer.java b/org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractHeaderTransformer.java deleted file mode 100644 index a44debac0f..0000000000 --- a/org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractHeaderTransformer.java +++ /dev/null @@ -1,46 +0,0 @@ -/* - * Copyright 2002-2008 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.transformer; - -import java.util.HashMap; -import java.util.Map; - -import org.springframework.integration.core.Message; -import org.springframework.integration.core.MessagingException; -import org.springframework.integration.message.MessageBuilder; - -/** - * A base class for {@link Transformer} implementations that modify - * the header values of a {@link Message}. - * - * @author Mark Fisher - */ -public abstract class AbstractHeaderTransformer implements Transformer { - - public final Message transform(Message message) { - try { - Map headerMap = new HashMap(message.getHeaders()); - this.transformHeaders(headerMap); - return MessageBuilder.withPayload(message.getPayload()).copyHeaders(headerMap).build(); - } catch (Exception e) { - throw new MessagingException(message, "failed to transform message headers", e); - } - } - - protected abstract void transformHeaders(Map headers); - -} diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/transformer/HeaderTransformerTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/transformer/HeaderTransformerTests.java deleted file mode 100644 index befd60f551..0000000000 --- a/org.springframework.integration/src/test/java/org/springframework/integration/transformer/HeaderTransformerTests.java +++ /dev/null @@ -1,74 +0,0 @@ -/* - * Copyright 2002-2008 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.transformer; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNull; - -import java.util.Map; - -import org.junit.Test; - -import org.springframework.integration.core.Message; -import org.springframework.integration.message.MessageBuilder; - -/** - * @author Mark Fisher - */ -public class HeaderTransformerTests { - - @Test - public void addHeader() { - AbstractHeaderTransformer transformer = new AbstractHeaderTransformer() { - @Override - protected void transformHeaders(Map headers) { - headers.put("header2", "baz"); - } - }; - Message message = MessageBuilder.withPayload("foo").setHeader("header1", "bar").build(); - Message result = transformer.transform(message); - assertEquals("bar", result.getHeaders().get("header1")); - assertEquals("baz", result.getHeaders().get("header2")); - } - - @Test - public void replaceHeader() { - AbstractHeaderTransformer transformer = new AbstractHeaderTransformer() { - @Override - protected void transformHeaders(Map headers) { - headers.put("header1", "baz"); - } - }; - Message message = MessageBuilder.withPayload("foo").setHeader("header1", "bar").build(); - Message result = transformer.transform(message); - assertEquals("baz", result.getHeaders().get("header1")); - } - - @Test - public void removeHeader() { - AbstractHeaderTransformer transformer = new AbstractHeaderTransformer() { - @Override - protected void transformHeaders(Map headers) { - headers.remove("header1"); - } - }; - Message message = MessageBuilder.withPayload("foo").setHeader("header1", "bar").build(); - Message result = transformer.transform(message); - assertNull(result.getHeaders().get("header1")); - } - -}