org.springframework.xd.dirt.server

Class StreamRuntimePropertiesProvider

java.lang.Object

org.springframework.xd.dirt.server.RuntimeModuleDeploymentPropertiesProvider

org.springframework.xd.dirt.server.StreamRuntimePropertiesProvider

All Implemented Interfaces:

ModuleDeploymentPropertiesProvider<RuntimeModuleDeploymentProperties>

public class StreamRuntimePropertiesProvider
extends RuntimeModuleDeploymentPropertiesProvider

RuntimeModuleDeploymentPropertiesProvider that provides the stream partition/short circuit properties for the given ModuleDescriptor.

Author:

Patrick Peralta, Mark Fisher, Ilayaperumal Gopinathan

Field Summary

Fields inherited from class org.springframework.xd.dirt.server.RuntimeModuleDeploymentPropertiesProvider

deploymentPropertiesProvider

Constructor Summary

Constructors

Constructor and Description
StreamRuntimePropertiesProvider(Stream stream, ModuleDeploymentPropertiesProvider<ModuleDeploymentProperties> propertiesProvider) Construct a StreamPartitionPropertiesProvider for a Stream.

Method Summary

Methods

Modifier and Type	Method and Description
RuntimeModuleDeploymentProperties	propertiesForDescriptor(ModuleDescriptor moduleDescriptor) Return the runtime deployment properties for the given module descriptor.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamRuntimePropertiesProvider

public StreamRuntimePropertiesProvider(Stream stream,
                               ModuleDeploymentPropertiesProvider<ModuleDeploymentProperties> propertiesProvider)

Construct a StreamPartitionPropertiesProvider for a Stream.

Parameters:

stream - stream to create partition properties for

Method Detail

propertiesForDescriptor

public RuntimeModuleDeploymentProperties propertiesForDescriptor(ModuleDescriptor moduleDescriptor)

Return the runtime deployment properties for the given module descriptor. Currently, this implementation assigns the module sequence for the given descriptor and add it to the runtime deployment properties.

Specified by:

propertiesForDescriptor in interface ModuleDeploymentPropertiesProvider<RuntimeModuleDeploymentProperties>

Overrides:

propertiesForDescriptor in class RuntimeModuleDeploymentPropertiesProvider

Parameters:

moduleDescriptor - module descriptor for module to be deployed

Returns:

deployment properties for module