org.springframework.cloud.dataflow.shell.command.classic

Class ClassicStreamCommands

java.lang.Object

org.springframework.cloud.dataflow.shell.command.common.AbstractStreamCommands

org.springframework.cloud.dataflow.shell.command.classic.ClassicStreamCommands

All Implemented Interfaces:

org.springframework.shell.core.CommandMarker

@Component
public class ClassicStreamCommands
extends AbstractStreamCommands
implements org.springframework.shell.core.CommandMarker

Stream commands.

Author:

Ilayaperumal Gopinathan, Mark Fisher, Gunnar Hillert, Glenn Renfro, Christian Tzolov, Janne Valkealahti

Field Summary

Fields inherited from class org.springframework.cloud.dataflow.shell.command.common.AbstractStreamCommands

dataFlowShell, PROPERTIES_FILE_OPTION, PROPERTIES_OPTION, userInput

Constructor Summary

Constructors

Constructor and Description
ClassicStreamCommands()

Method Summary

Modifier and Type	Method and Description
boolean	availableWithCreateRole()
String	deployStream(String name, String deploymentProperties, File propertiesFile)
void	setDataFlowShell(DataFlowShell dataFlowShell)
void	setUserInput(UserInput userInput)

Methods inherited from class org.springframework.cloud.dataflow.shell.command.common.AbstractStreamCommands

availableWithViewRole, createStream, destroyAllStreams, destroyStream, listStreams, streamInfo, streamOperations, undeployAllStreams, undeployStream

Methods inherited from class java.lang.Object

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

Constructor Detail

ClassicStreamCommands

public ClassicStreamCommands()

Method Detail

setDataFlowShell

@Autowired
public void setDataFlowShell(DataFlowShell dataFlowShell)

setUserInput

@Autowired
public void setUserInput(UserInput userInput)

availableWithCreateRole

@CliAvailabilityIndicator(value="stream deploy")
public boolean availableWithCreateRole()

Overrides:

availableWithCreateRole in class AbstractStreamCommands

deployStream

@CliCommand(value="stream deploy",
            help="Deploy a previously created stream")
public String deployStream(@CliOption(key={"","name"},help="the name of the stream to deploy",mandatory=true,optionContext="existing-stream disable-string-converter")
                                                                                                                     String name,
                                                                                                                     @CliOption(key="properties",help="the properties for this deployment")
                                                                                                                     String deploymentProperties,
                                                                                                                     @CliOption(key="propertiesFile",help="the properties for this deployment (as a File)")
                                                                                                                     File propertiesFile)
                                                                                                              throws IOException

Throws:

IOException