org.springframework.xd.rest.client.impl

Class StreamTemplate

java.lang.Object

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

All Implemented Interfaces:

StreamOperations

public class StreamTemplate
extends java.lang.Object
implements StreamOperations

Implementation of the Stream-related part of the API.

Author:

Eric Bottard

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<java.lang.String,java.net.URI>	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	deployStream(java.lang.String name) Deploy an already created stream.
void	destroyStream(java.lang.String name) Destroy an existing stream.
StreamDefinitionResource.Page	list() List streams known to the system.
void	undeployStream(java.lang.String name) Undeploy a deployed stream, retaining its definition.

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,java.net.URI> 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

destroyStream

public void destroyStream(java.lang.String name)

Description copied from interface: StreamOperations

Destroy an existing stream.

Specified by:

destroyStream in interface StreamOperations

deployStream

public void deployStream(java.lang.String name)

Description copied from interface: StreamOperations

Deploy an already created stream.

Specified by:

deployStream in interface StreamOperations

undeployStream

public void undeployStream(java.lang.String name)

Description copied from interface: StreamOperations

Undeploy a deployed stream, retaining its definition.

Specified by:

undeployStream 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