org.springframework.xd.integration.util

Class XdEnvironment

java.lang.Object

org.springframework.xd.integration.util.XdEnvironment

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware

public class XdEnvironment
extends java.lang.Object
implements org.springframework.beans.factory.BeanClassLoaderAware

Extracts the host and port information for the XD Instances. Assumes that the host that runs the RabbitMQ broker is the same host that runs the admin server.

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	HTTP_PREFIX
static java.lang.String	RESULT_LOCATION
static java.lang.String	XD_ADMIN_HOST
static java.lang.String	XD_HTTP_PORT
static java.lang.String	XD_JMX_PORT

Constructor Summary

Constructors

Constructor and Description
XdEnvironment()

Method Summary

Methods

Modifier and Type	Method and Description
java.net.URL	getAdminServerUrl()
java.lang.String	getBaseDir()
java.lang.String	getContainerLogLocation()
java.lang.String	getDataNodePort() The hadoop data node port that is available for this environment.
javax.sql.DataSource	getDataSource()
java.lang.String	getGemfireHost() Retrieves the Gemfire host.
int	getGemfirePort() Retrieves the Gemfire port.
int	getHttpPort()
java.lang.String	getJmsHost()
int	getJmsPort()
int	getJmxPort()
org.springframework.data.mongodb.MongoDbFactory	getMongoDbFactory() The mongo db factory to be used for the tests.
java.lang.String	getMongoHost() Retrieves the host where the mongo server is running.
java.lang.String	getMongoPort() Retrieves the port that the mongo server is monitoring.
java.lang.String	getNameNode() The hadoop name node that is available for this environment.
java.lang.String	getPrivateKey()
org.springframework.amqp.rabbit.connection.CachingConnectionFactory	getRabbitConnectionFactory()
java.lang.String	getRabbitMQHost() Default value is the same as the admin server host.
java.lang.String	getTwitterAccessToken() The Twitter Access Token
java.lang.String	getTwitterAccessTokenSecret() The Twitter Access Token Secret
java.lang.String	getTwitterConsumerKey() The twitter consumer key
java.lang.String	getTwitterConsumerSecretKey() The twitter consumer secret key
void	initalizeEc2Environment() If not running tests on a local XD Instance it will retrieve the information from the artifact and setup the environment to test against a remote XD.
boolean	isOnEc2()
void	setBeanClassLoader(java.lang.ClassLoader beanClassLoader)

Methods inherited from class java.lang.Object

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

Field Detail

XD_ADMIN_HOST

public static final java.lang.String XD_ADMIN_HOST

See Also:

Constant Field Values

XD_HTTP_PORT

public static final java.lang.String XD_HTTP_PORT

See Also:

Constant Field Values

XD_JMX_PORT

public static final java.lang.String XD_JMX_PORT

See Also:

Constant Field Values

RESULT_LOCATION

public static final java.lang.String RESULT_LOCATION

See Also:

Constant Field Values

HTTP_PREFIX

public static final java.lang.String HTTP_PREFIX

See Also:

Constant Field Values

Constructor Detail

XdEnvironment

public XdEnvironment()

Method Detail

initalizeEc2Environment

@PostConstruct
public void initalizeEc2Environment()
                             throws java.net.MalformedURLException

If not running tests on a local XD Instance it will retrieve the information from the artifact and setup the environment to test against a remote XD. Als initializes the dataSource for JDBC Tests.

Throws:

java.net.MalformedURLException

setBeanClassLoader

public void setBeanClassLoader(java.lang.ClassLoader beanClassLoader)

Specified by:

setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAware

getAdminServerUrl

public java.net.URL getAdminServerUrl()

getJmxPort

public int getJmxPort()

getHttpPort

public int getHttpPort()

getPrivateKey

public java.lang.String getPrivateKey()

isOnEc2

public boolean isOnEc2()

getContainerLogLocation

public java.lang.String getContainerLogLocation()

getBaseDir

public java.lang.String getBaseDir()

getDataSource

public javax.sql.DataSource getDataSource()

getRabbitConnectionFactory

public org.springframework.amqp.rabbit.connection.CachingConnectionFactory getRabbitConnectionFactory()

getJmsHost

public java.lang.String getJmsHost()

getJmsPort

public int getJmsPort()

getRabbitMQHost

public java.lang.String getRabbitMQHost()

Default value is the same as the admin server host.

Returns:

the host where the rabbitmq broker is running.

getTwitterConsumerKey

public java.lang.String getTwitterConsumerKey()

The twitter consumer key

Returns:

consumer key

getTwitterConsumerSecretKey

public java.lang.String getTwitterConsumerSecretKey()

The twitter consumer secret key

Returns:

consumer secret key

getTwitterAccessToken

public java.lang.String getTwitterAccessToken()

The Twitter Access Token

Returns:

twitter access token

getTwitterAccessTokenSecret

public java.lang.String getTwitterAccessTokenSecret()

The Twitter Access Token Secret

Returns:

twitter access token secret

getNameNode

public java.lang.String getNameNode()

The hadoop name node that is available for this environment.

Returns:

the hadoop name node.

getDataNodePort

public java.lang.String getDataNodePort()

The hadoop data node port that is available for this environment.

Returns:

the data node port.

getMongoDbFactory

public org.springframework.data.mongodb.MongoDbFactory getMongoDbFactory()

The mongo db factory to be used for the tests.

Returns:

The current mongoDbFactory instance.

getMongoHost

public java.lang.String getMongoHost()

Retrieves the host where the mongo server is running.

Returns:

the mongo host

getMongoPort

public java.lang.String getMongoPort()

Retrieves the port that the mongo server is monitoring.

Returns:

the mongo server port.

getGemfireHost

public java.lang.String getGemfireHost()

Retrieves the Gemfire host.

Returns:

the host

getGemfirePort

public int getGemfirePort()

Retrieves the Gemfire port.

Returns:

the port