org.springframework.xd.dirt.stream

Class StreamFactory

java.lang.Object

org.springframework.xd.dirt.stream.StreamFactory

public class StreamFactory
extends java.lang.Object

Factory class that builds Stream instances.

Author:

Patrick Peralta, Mark Fisher

Constructor Summary

Constructors

Constructor and Description
StreamFactory(StreamDefinitionRepository streamDefinitionRepository, ModuleRegistry moduleRegistry, ModuleOptionsMetadataResolver moduleOptionsMetadataResolver) Construct a StreamFactory to create Stream domain model instances.

Method Summary

Methods

Modifier and Type	Method and Description
Stream	createStream(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties) Create a new instance of Stream for the given name and properties.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamFactory

public StreamFactory(StreamDefinitionRepository streamDefinitionRepository,
             ModuleRegistry moduleRegistry,
             ModuleOptionsMetadataResolver moduleOptionsMetadataResolver)

Construct a StreamFactory to create Stream domain model instances.

Parameters:

streamDefinitionRepository - repository for stream definitions

moduleRegistry - registry for module definitions

moduleOptionsMetadataResolver - resolver for module options metadata

Method Detail

createStream

public Stream createStream(java.lang.String name,
                  java.util.Map<java.lang.String,java.lang.String> properties)

Create a new instance of Stream for the given name and properties. The properties should at minimum contain the following entries:

definition	DSL definition for stream
deploymentProperties	Deployment properties for stream

Parameters:

name - stream name

properties - properties for stream

Returns:

new Stream domain model instance