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

INT-1214 HttpRequestHandlingMessagingGateway now uses DefaultHttpHeaderMapper by default but exposes a setter for other implementations of HeaderMapper<HttpHeaders>

Browse Source
This commit is contained in:
Mark Fisher
2010-07-26 18:17:43 +00:00
parent 53ddea4b63
commit d3a85c6b02
1 changed files with 9 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
spring-integration-http/src/main/java/org/springframework/integration/http/HttpRequestHandlingMessagingGateway.java
View File

@@ -41,7 +41,6 @@ import org.springframework.http.converter.xml.SourceHttpMessageConverter;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.http.server.ServletServerHttpResponse;
import org.springframework.integration.core.Message;
import org.springframework.integration.core.MessageHeaders;
import org.springframework.integration.core.MessagingException;
import org.springframework.integration.gateway.AbstractMessagingGateway;
import org.springframework.integration.message.HeaderMapper;
@@ -99,7 +98,7 @@ public class HttpRequestHandlingMessagingGateway extends AbstractMessagingGatewa
private volatile List<HttpMessageConverter<?>> messageConverters = new ArrayList<HttpMessageConverter<?>>();
private volatile HeaderMapper<HttpHeaders> headerMapper = new DefaultHeaderMapper();
private volatile HeaderMapper<HttpHeaders> headerMapper = new DefaultHttpHeaderMapper();
private final boolean expectReply;
@@ -142,6 +141,14 @@ public class HttpRequestHandlingMessagingGateway extends AbstractMessagingGatewa
this.messageConverters = messageConverters;
}
/**
* Set the {@link HeaderMapper} to use when mapping between HTTP headers and MessageHeaders.
*/
public void setHeaderMapper(HeaderMapper<HttpHeaders> headerMapper) {
Assert.notNull(headerMapper, "headerMapper must not be null");
this.headerMapper = headerMapper;
}
/**
* Specify the supported request methods for this gateway.
* By default, only GET and POST are supported.
@@ -316,21 +323,4 @@ public class HttpRequestHandlingMessagingGateway extends AbstractMessagingGatewa
payload.getClass().getName() + "] and content types [" + acceptTypes + "]");
}
private static class DefaultHeaderMapper implements HeaderMapper<HttpHeaders> {
public void fromHeaders(MessageHeaders headers, HttpHeaders target) {
for (String name : headers.keySet()) {
Object value = headers.get(name);
if (value instanceof String) {
target.add(name, (String) value);
}
}
}
public Map<String, ?> toHeaders(HttpHeaders source) {
return source;
}
}
}