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, Paul Harris, Gary Russell

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
void	cleanBusResources(java.lang.String name) Remove any bus resources that cannot be automatically removed during undeploy.
StreamDefinitionResource	createStream(java.lang.String name, java.lang.String definition, boolean deploy) Create a new Stream, optionally deploying it.
void	deploy(java.lang.String name, java.util.Map<java.lang.String,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

Methods inherited from interface org.springframework.xd.rest.client.ResourceOperations

cleanBusResources, deploy, destroy, destroyAll, undeploy, undeployAll

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 definition,
                                    boolean deploy)

Description copied from interface: StreamOperations

Create a new Stream, optionally deploying it.

Specified by:

createStream in interface StreamOperations

list

public StreamDefinitionResource.Page list()

Description copied from interface: StreamOperations

List streams known to the system.

Specified by:

list 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.util.Map<java.lang.String,java.lang.String> properties)

Description copied from interface: ResourceOperations

Deploy an already created resource.

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

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

cleanBusResources

public void cleanBusResources(java.lang.String name)

Description copied from interface: ResourceOperations

Remove any bus resources that cannot be automatically removed during undeploy.

Specified by:

cleanBusResources in interface ResourceOperations