org.springframework.xd.integration.util

Class StreamUtils

java.lang.Object

org.springframework.xd.integration.util.StreamUtils

public class StreamUtils
extends java.lang.Object

Utilities for creating and monitoring streams and the JMX hooks for those strings.

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	TMP_DIR

Constructor Summary

Constructors

Constructor and Description
StreamUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static void	destroyAllStreams(java.util.List<java.lang.String> streamNames, java.net.URL adminServer)
static java.lang.String	httpGet(java.net.URL url)
static java.net.URL	replacePort(java.net.URL url, int port)
static void	stream(java.lang.String streamName, java.lang.String streamDefinition, java.net.URL adminServer)
static java.lang.String	transferLogToTmp(XdEnvironment hosts, java.net.URL url, java.lang.String fileName)
static java.lang.String	transferResultsToLocal(XdEnvironment hosts, java.net.URL url, java.lang.String fileName)

Methods inherited from class java.lang.Object

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

Field Detail

TMP_DIR

public static final java.lang.String TMP_DIR

See Also:

Constant Field Values

Constructor Detail

StreamUtils

public StreamUtils()

Method Detail

stream

public static void stream(java.lang.String streamName,
          java.lang.String streamDefinition,
          java.net.URL adminServer)
                   throws java.io.IOException,
                          java.net.URISyntaxException

Throws:

java.io.IOException

java.net.URISyntaxException

httpGet

public static java.lang.String httpGet(java.net.URL url)
                                throws java.io.IOException

Throws:

java.io.IOException

destroyAllStreams

public static void destroyAllStreams(java.util.List<java.lang.String> streamNames,
                     java.net.URL adminServer)
                              throws java.net.URISyntaxException,
                                     java.io.IOException

Throws:

java.net.URISyntaxException

java.io.IOException

transferResultsToLocal

public static java.lang.String transferResultsToLocal(XdEnvironment hosts,
                                      java.net.URL url,
                                      java.lang.String fileName)
                                               throws java.io.IOException

Throws:

java.io.IOException

transferLogToTmp

public static java.lang.String transferLogToTmp(XdEnvironment hosts,
                                java.net.URL url,
                                java.lang.String fileName)
                                         throws java.io.IOException

Throws:

java.io.IOException

replacePort

public static java.net.URL replacePort(java.net.URL url,
                       int port)
                                throws java.net.MalformedURLException

Throws:

java.net.MalformedURLException