@RestController @RequestMapping(value="/${spring.cloud.stream.binder.servlet.prefix:stream}") public class MessageController extends Object implements RouteRegistrar
Modifier and Type | Field and Description |
---|---|
static String |
ROUTE_KEY |
long |
timeoutSeconds |
Constructor and Description |
---|
MessageController(String prefix,
EnabledBindings bindings) |
Modifier and Type | Method and Description |
---|---|
void |
bind(String name,
String group,
org.springframework.messaging.MessageChannel inputTarget) |
org.springframework.http.ResponseEntity<Object> |
function(String path,
Object body,
org.springframework.http.HttpHeaders headers) |
org.springframework.cloud.stream.binder.servlet.MessageController.Route |
input(String path) |
org.springframework.http.ResponseEntity<Object> |
json(String path,
String body,
org.springframework.http.HttpHeaders headers) |
org.springframework.cloud.stream.binder.servlet.MessageController.Route |
output(String path) |
void |
registerRoutes(Set<String> routes) |
void |
reset() |
void |
setBufferTimeoutSeconds(long timeoutSeconds) |
void |
setReceiveTimeoutSeconds(long receiveTimeoutMillis) |
org.springframework.http.ResponseEntity<org.springframework.web.servlet.mvc.method.annotation.SseEmitter> |
sse(String path,
org.springframework.http.HttpHeaders headers) |
org.springframework.http.ResponseEntity<Object> |
string(String path,
String body,
org.springframework.http.HttpHeaders headers) |
void |
subscribe(String name,
org.springframework.messaging.SubscribableChannel outboundBindTarget) |
org.springframework.http.ResponseEntity<Object> |
supplier(String path,
org.springframework.http.HttpHeaders headers,
boolean purge) |
void |
unregisterRoutes(Set<String> routes) |
public static final String ROUTE_KEY
public long timeoutSeconds
public MessageController(String prefix, EnabledBindings bindings)
public void setReceiveTimeoutSeconds(long receiveTimeoutMillis)
public void setBufferTimeoutSeconds(long timeoutSeconds)
@GetMapping(path="/**", produces="text/event-stream") public org.springframework.http.ResponseEntity<org.springframework.web.servlet.mvc.method.annotation.SseEmitter> sse(@RequestAttribute(value="org.springframework.web.servlet.HandlerMapping.pathWithinHandlerMapping") String path, @RequestHeader org.springframework.http.HttpHeaders headers) throws IOException
IOException
@GetMapping(value="/**") public org.springframework.http.ResponseEntity<Object> supplier(@RequestAttribute(value="org.springframework.web.servlet.HandlerMapping.pathWithinHandlerMapping") String path, @RequestHeader org.springframework.http.HttpHeaders headers, @RequestParam(required=false) boolean purge)
@PostMapping(path="/**", consumes="text/plain") public org.springframework.http.ResponseEntity<Object> string(@RequestAttribute(value="org.springframework.web.servlet.HandlerMapping.pathWithinHandlerMapping") String path, @RequestBody String body, @RequestHeader org.springframework.http.HttpHeaders headers)
@PostMapping(path="/**", consumes="application/json") public org.springframework.http.ResponseEntity<Object> json(@RequestAttribute(value="org.springframework.web.servlet.HandlerMapping.pathWithinHandlerMapping") String path, @RequestBody String body, @RequestHeader org.springframework.http.HttpHeaders headers)
@PostMapping(value="/**") public org.springframework.http.ResponseEntity<Object> function(@RequestAttribute(value="org.springframework.web.servlet.HandlerMapping.pathWithinHandlerMapping") String path, @RequestBody Object body, @RequestHeader org.springframework.http.HttpHeaders headers)
public void reset()
public void subscribe(String name, org.springframework.messaging.SubscribableChannel outboundBindTarget)
public void bind(String name, String group, org.springframework.messaging.MessageChannel inputTarget)
public org.springframework.cloud.stream.binder.servlet.MessageController.Route output(String path)
public org.springframework.cloud.stream.binder.servlet.MessageController.Route input(String path)
public void registerRoutes(Set<String> routes)
registerRoutes
in interface RouteRegistrar
public void unregisterRoutes(Set<String> routes)
unregisterRoutes
in interface RouteRegistrar
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.