org.springframework.xd.integration.util

Class XdEc2Validation

java.lang.Object

org.springframework.xd.integration.util.XdEc2Validation

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()

Method Summary

Methods

Modifier and Type	Method and Description
void	assertReceived(java.net.URL url, java.lang.String streamName, java.lang.String moduleName) Retrieves the stream and verifies that the module has infact processed the data.
void	verifyAtLeastOneContainerAvailable(java.util.List<java.net.URL> containers, int jmxPort) * Checks to see if at least one server the user specified is available.
void	verifyLogContent(XdEnvironment hosts, java.net.URL url, java.lang.String fileName, java.lang.String data) checks to see if the content of the data passed in is in the log.
void	verifyTestContent(XdEnvironment hosts, 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) Checks to see if the admin server the user specified 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()

Method Detail

verifyXDAdminReady

public void verifyXDAdminReady(java.net.URL adminServer)

Checks to see if the admin server the user specified is available. Else it throws a ResourceAccessException.

Parameters:

adminServer -

verifyAtLeastOneContainerAvailable

public void verifyAtLeastOneContainerAvailable(java.util.List<java.net.URL> containers,
                                      int jmxPort)
                                        throws java.lang.Exception

* Checks to see if at least one server the user specified is available. Else it throws a ResourceAccessException.

Parameters:

containers -

jmxPort -

Throws:

java.lang.Exception

assertReceived

public void assertReceived(java.net.URL url,
                  java.lang.String streamName,
                  java.lang.String moduleName)
                    throws java.lang.Exception

Retrieves the stream and verifies that the module has infact processed the data.

Parameters:

url - The server where the stream is deployed

streamName - The stream to analyze.

moduleName - The name of the module

Throws:

java.lang.Exception

verifyTestContent

public void verifyTestContent(XdEnvironment hosts,
                     java.net.URL url,
                     java.lang.String fileName,
                     java.lang.String data)
                       throws java.io.IOException

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

Parameters:

hosts - Helper class for retrieving files.

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.

Throws:

java.io.IOException

verifyLogContent

public void verifyLogContent(XdEnvironment hosts,
                    java.net.URL url,
                    java.lang.String fileName,
                    java.lang.String data)
                      throws java.io.IOException

checks to see if the content of the data passed in is in the log.

Parameters:

hosts - Helper class for retrieving log files

url - The URL of the server to where the stream is deployed.

fileName - The name of the log file to inspect

data - THe expected result.

Throws:

java.io.IOException