org.springframework.xd.rest.client.impl

Class StreamTemplate

java.lang.Object

org.springframework.xd.rest.client.impl.StreamTemplate

All Implemented Interfaces:

ResourceOperations, StreamOperations

public class StreamTemplate
extends java.lang.Object
implements StreamOperations

Implementation of the Stream-related part of the API.

Author:

Eric Bottard, Ilayaperumal Gopinathan

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<java.lang.String,org.springframework.hateoas.UriTemplate>	resources Holds discovered URLs of the API.
protected org.springframework.web.client.RestTemplate	restTemplate A template used for http interaction.

Method Summary

Methods

Modifier and Type	Method and Description
StreamDefinitionResource	createStream(java.lang.String name, java.lang.String defintion, boolean deploy) Create a new Stream, optionally deploying it.
void	deploy(java.lang.String name, java.lang.String properties) Deploy an already created resource.
void	destroy(java.lang.String name) Destroy an existing resource.
void	destroyAll() Undeploy all the resources known to the system.
StreamDefinitionResource.Page	list() List streams known to the system.
void	undeploy(java.lang.String name) Undeploy a deployed resource, retaining its definition.
void	undeployAll() Undeploy all the resources known to the system.

Methods inherited from class java.lang.Object

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

Field Detail

restTemplate

protected org.springframework.web.client.RestTemplate restTemplate

A template used for http interaction.

resources

protected java.util.Map<java.lang.String,org.springframework.hateoas.UriTemplate> resources

Holds discovered URLs of the API.

Method Detail

createStream

public StreamDefinitionResource createStream(java.lang.String name,
                                    java.lang.String defintion,
                                    boolean deploy)

Description copied from interface: StreamOperations

Create a new Stream, optionally deploying it.

Specified by:

createStream in interface StreamOperations

destroy

public void destroy(java.lang.String name)

Description copied from interface: ResourceOperations

Destroy an existing resource.

Specified by:

destroy in interface ResourceOperations

deploy

public void deploy(java.lang.String name,
          java.lang.String properties)

Description copied from interface: ResourceOperations

Deploy an already created resource. Optionally providing deployment properties, as a comma-delimited list of key=value pairs.

Specified by:

deploy in interface ResourceOperations

undeploy

public void undeploy(java.lang.String name)

Description copied from interface: ResourceOperations

Undeploy a deployed resource, retaining its definition.

Specified by:

undeploy in interface ResourceOperations

list

public StreamDefinitionResource.Page list()

Description copied from interface: StreamOperations

List streams known to the system.

Specified by:

list in interface StreamOperations

undeployAll

public void undeployAll()

Description copied from interface: ResourceOperations

Undeploy all the resources known to the system.

Specified by:

undeployAll in interface ResourceOperations

destroyAll

public void destroyAll()

Description copied from interface: ResourceOperations

Undeploy all the resources known to the system.

Specified by:

destroyAll in interface ResourceOperations