@Controller @RequestMapping(value="/streams") @ExposesResourceFor(value=StreamDefinitionResource.class) public class StreamsController extends XDController<StreamDefinition,StreamDefinitionResourceAssembler,StreamDefinitionResource,Stream>
XDController.QueryOptions| Constructor and Description |
|---|
StreamsController(StreamDeployer streamDeployer) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
clean(java.lang.String stream,
java.lang.String adminUri,
java.lang.String user,
java.lang.String pw,
java.lang.String vhost,
java.lang.String busPrefix) |
protected StreamDefinition |
createDefinition(java.lang.String name,
java.lang.String definition) |
org.springframework.hateoas.PagedResources<StreamDefinitionResource> |
list(org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<StreamDefinition> assembler)
List stream definitions.
|
cleanRabbitBus, delete, deleteAll, deploy, display, listValues, save, undeploy, undeployAll@Autowired public StreamsController(StreamDeployer streamDeployer)
@ResponseBody
@RequestMapping(value="/definitions",
method=GET)
@ResponseStatus(value=OK)
public org.springframework.hateoas.PagedResources<StreamDefinitionResource> list(org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<StreamDefinition> assembler)
protected StreamDefinition createDefinition(java.lang.String name, java.lang.String definition)
createDefinition in class XDController<StreamDefinition,StreamDefinitionResourceAssembler,StreamDefinitionResource,Stream>@ResponseBody
@RequestMapping(value="/clean/rabbit/{stream}",
method=DELETE)
@ResponseStatus(value=OK)
public java.util.Map<java.lang.String,java.util.List<java.lang.String>> clean(@PathVariable
java.lang.String stream,
@RequestParam(required=false)
java.lang.String adminUri,
@RequestParam(required=false)
java.lang.String user,
@RequestParam(required=false)
java.lang.String pw,
@RequestParam(required=false)
java.lang.String vhost,
@RequestParam(required=false)
java.lang.String busPrefix)