org.springframework.xd.dirt.stream.dsl

Class StreamNode

java.lang.Object

org.springframework.xd.dirt.stream.dsl.AstNode

org.springframework.xd.dirt.stream.dsl.StreamNode

public class StreamNode
extends AstNode

Author:

Andy Clement

Field Summary

Fields inherited from class org.springframework.xd.dirt.stream.dsl.AstNode

endpos, startpos

Constructor Summary

Constructors

Constructor and Description
StreamNode(java.lang.String streamName, java.util.List<ModuleNode> moduleNodes, SourceChannelNode sourceChannelNode, SinkChannelNode sinkChannelNode)

Method Summary

Methods

Modifier and Type	Method and Description
int	getIndexOfLabelOrModuleName(java.lang.String labelOrModuleName)
ModuleNode	getModule(java.lang.String moduleName) Find the first reference to the named module in the stream.
java.util.List<ModuleNode>	getModuleNodes()
SinkChannelNode	getSinkChannelNode()
SourceChannelNode	getSourceChannelNode()
java.lang.String	getStreamData()
java.lang.String	getStreamName()
void	resolve(StreamLookupEnvironment env)
void	resolveModuleNodes(StreamLookupEnvironment env, java.util.List<ModuleNode> moduleNodes) Does the lookup of module nodes to see if any previously defined and if so replaces them in this stream
java.lang.String	stringify(boolean includePositionalInfo)
java.lang.String	toString()

Methods inherited from class org.springframework.xd.dirt.stream.dsl.AstNode

getEndPos, getStartPos, stringify

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamNode

public StreamNode(java.lang.String streamName,
          java.util.List<ModuleNode> moduleNodes,
          SourceChannelNode sourceChannelNode,
          SinkChannelNode sinkChannelNode)

Method Detail

stringify

public java.lang.String stringify(boolean includePositionalInfo)

Specified by:

stringify in class AstNode

Returns:

a string representation of the AST. Useful for debugging/testing.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getModuleNodes

public java.util.List<ModuleNode> getModuleNodes()

getSourceChannelNode

public SourceChannelNode getSourceChannelNode()

getSinkChannelNode

public SinkChannelNode getSinkChannelNode()

getStreamName

public java.lang.String getStreamName()

getModule

public ModuleNode getModule(java.lang.String moduleName)

Find the first reference to the named module in the stream. If the same module is referred to multiple times the secondary references cannot be accessed via this method.

Returns:

the first occurrence of the named module in the stream

resolve

public void resolve(StreamLookupEnvironment env)

resolveModuleNodes

public void resolveModuleNodes(StreamLookupEnvironment env,
                      java.util.List<ModuleNode> moduleNodes)

Does the lookup of module nodes to see if any previously defined and if so replaces them in this stream

getIndexOfLabelOrModuleName

public int getIndexOfLabelOrModuleName(java.lang.String labelOrModuleName)

getStreamData

public java.lang.String getStreamData()