org.springframework.xd.dirt.rest

Class StreamsController

java.lang.Object

org.springframework.xd.dirt.rest.XDController<StreamDefinition,StreamDefinitionResourceAssembler,StreamDefinitionResource>

org.springframework.xd.dirt.rest.StreamsController

@Controller
@RequestMapping(value="/streams")
@ExposesResourceFor(value=StreamDefinitionResource.class)
public class StreamsController
extends XDController<StreamDefinition,StreamDefinitionResourceAssembler,StreamDefinitionResource>

Handles all Stream related interaction.

Since:

1.0

Author:

Eric Bottard, Gunnar Hillert, David Turanski

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.xd.dirt.rest.XDController

XDController.QueryOptions

Constructor Summary

Constructors

Constructor and Description
StreamsController(StreamDeployer streamDeployer, StreamDefinitionRepository streamDefinitionRepository)

Method Summary

Methods

Modifier and Type	Method and Description
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.

Methods inherited from class org.springframework.xd.dirt.rest.XDController

delete, deleteAll, deploy, display, getDeployer, listValues, save, undeploy, undeployAll

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamsController

@Autowired
public StreamsController(StreamDeployer streamDeployer,
                           StreamDefinitionRepository streamDefinitionRepository)

Method Detail

list

@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)

List stream definitions.

createDefinition

protected StreamDefinition createDefinition(java.lang.String name,
                                java.lang.String definition)

Specified by:

createDefinition in class XDController<StreamDefinition,StreamDefinitionResourceAssembler,StreamDefinitionResource>