org.springframework.xd.integration.util

Class XdEc2Validation

java.lang.Object

org.springframework.xd.integration.util.XdEc2Validation

@Configuration
public class XdEc2Validation
extends java.lang.Object

Validates that all instances of the cluster is up and running. Also verifies that streams are running and available.

Author:

Glenn Renfro

Constructor Summary

Constructors

Constructor and Description
XdEc2Validation(HadoopUtils hadoopUtil, XdEnvironment xdEnvironment) Construct a new instance of XdEc2Validation

Method Summary

Methods

Modifier and Type	Method and Description
void	assertReceived(java.net.URL url, java.lang.String streamName, int msgCountExpected) Retrieves the stream and verifies that all modules in the stream processed the data.
void	assertReceived(java.net.URL url, java.lang.String streamName, java.lang.String moduleName, java.lang.String channelName, int msgCountExpected) Verifies that the instances for the channel and module has in fact processed the correct number of messages.
void	verifyContentContains(java.net.URL url, java.lang.String fileName, java.lang.String data) Verifies that the data user gave us is contained in the result.
void	verifyContentContainsIgnoreCase(java.net.URL url, java.lang.String fileName, java.lang.String data) Verifies that the data user gave us is contained in the result.
void	verifyHdfsTestContent(java.lang.String expectedResult, java.lang.String pathToHdfsFile) Evaluates the content of the hdfs file against a result.
void	verifyLogContains(java.net.URL url, java.lang.String data) Verifies that the data is contained in the container log.
void	verifyTestContent(java.net.URL url, java.lang.String fileName, java.lang.String data) Verifies that the data user gave us is what was stored after the stream has processed the flow.
void	verifyXDAdminReady(java.net.URL adminServer) Assert is the admin server is available.

Methods inherited from class java.lang.Object

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

Constructor Detail

XdEc2Validation

public XdEc2Validation(HadoopUtils hadoopUtil,
               XdEnvironment xdEnvironment)

Construct a new instance of XdEc2Validation

Method Detail

verifyXDAdminReady

public void verifyXDAdminReady(java.net.URL adminServer)

Assert is the admin server is available.

Parameters:

adminServer - the location of the admin server

assertReceived

public void assertReceived(java.net.URL url,
                  java.lang.String streamName,
                  java.lang.String moduleName,
                  java.lang.String channelName,
                  int msgCountExpected)

Verifies that the instances for the channel and module has in fact processed the correct number of messages. Keep in mind that any module name must be suffixed with index number for example .1. So if I have a stream of http|file, to access the modules I will need to have a module name of http.1 for the source and file.1 for the sink.

Parameters:

url - The server where the stream is deployed

streamName - The stream to analyze.

moduleName - The name of the module.

channelName - The name of the channel to interrogate.

msgCountExpected - expected number of messages to have been successfully processed by the module.

assertReceived

public void assertReceived(java.net.URL url,
                  java.lang.String streamName,
                  int msgCountExpected)

Retrieves the stream and verifies that all modules in the stream processed the data.

Parameters:

url - The server where the stream is deployed

streamName - The stream to analyze.

Throws:

java.lang.Exception - Error processing JSON or making HTTP GET request

verifyTestContent

public void verifyTestContent(java.net.URL url,
                     java.lang.String fileName,
                     java.lang.String data)

Verifies that the data user gave us is what was stored after the stream has processed the flow.

Parameters:

url - The server that the stream is deployed.

fileName - The file that contains the data to check.

data - The data used to evaluate the results of the stream.

verifyLogContains

public void verifyLogContains(java.net.URL url,
                     java.lang.String data)

Verifies that the data is contained in the container log.

Parameters:

url - The server where the container is deployed.

data - the value that will be searched for, within the log file.

verifyContentContains

public void verifyContentContains(java.net.URL url,
                         java.lang.String fileName,
                         java.lang.String data)

Verifies that the data user gave us is contained in the result.

Parameters:

url - The server where the container is deployed.

fileName - The file that contains the data to check.

data - The data used to evaluate the results of the stream.

verifyContentContainsIgnoreCase

public void verifyContentContainsIgnoreCase(java.net.URL url,
                                   java.lang.String fileName,
                                   java.lang.String data)

Verifies that the data user gave us is contained in the result.

Parameters:

url - The server that the stream is deployed.

fileName - The file that contains the data to check.

data - The data used to evaluate the results of the stream.

verifyHdfsTestContent

public void verifyHdfsTestContent(java.lang.String expectedResult,
                         java.lang.String pathToHdfsFile)

Evaluates the content of the hdfs file against a result. If equal no action is taken else an assert is thrown.

Parameters:

expectedResult - The data that should be within the hdfs file.

pathToHdfsFile - The location of the file on the hdfs file system