org.springframework.cloud.stream.app.http.source

Class HttpSourceConfiguration

java.lang.Object

org.springframework.cloud.stream.app.http.source.HttpSourceConfiguration

@Controller
 @EnableBinding(value=org.springframework.cloud.stream.messaging.Source.class)
public class HttpSourceConfiguration
extends Object

A source module that listens for HTTP requests and emits the body as a message payload. If the Content-Type matches 'text/*' or 'application/json', the payload will be a String, otherwise the payload will be a byte array.

Author:

Eric Bottard, Mark Fisher, Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
HttpSourceConfiguration()

Method Summary

Modifier and Type	Method and Description
void	handleRequest(byte[] body, Object contentType)
void	handleRequest(String body, Object contentType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpSourceConfiguration

public HttpSourceConfiguration()

Method Detail

handleRequest

@RequestMapping(path="${http.pathPattern:/}",
                method=POST,
                consumes={"text/*","application/json"})
 @ResponseStatus(value=ACCEPTED)
public void handleRequest(@RequestBody
                                                                                                                                                                                              String body,
                                                                                                                                                                                              @RequestHeader(value="Content-Type")
                                                                                                                                                                                              Object contentType)

handleRequest

@RequestMapping(path="${http.pathPattern:/}",
                method=POST,
                consumes="*/*")
 @ResponseStatus(value=ACCEPTED)
public void handleRequest(@RequestBody
                                                                                                                                                                      byte[] body,
                                                                                                                                                                      @RequestHeader(value="Content-Type")
                                                                                                                                                                      Object contentType)