Repository: stratos Updated Branches: refs/heads/stratos-4.1.x 10ea238e1 -> a62c8ce79
Fixing failing test cases Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/443f20ae Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/443f20ae Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/443f20ae Branch: refs/heads/stratos-4.1.x Commit: 443f20aefe5c77a826f9f0b2a95d1aee8b40f4da Parents: b6ebf56 Author: Pubudu Gunatilaka <[email protected]> Authored: Thu Nov 12 15:42:45 2015 +0530 Committer: Pubudu Gunatilaka <[email protected]> Committed: Thu Nov 12 15:42:45 2015 +0530 ---------------------------------------------------------------------- .../integration/tests/CEPHAModeTestCase.java | 34 ++++++++++++-------- .../tests/PythonAgentIntegrationTest.java | 18 ++++++----- .../CEPHAModeTestCase/payload/launch-params | 2 +- .../test-conf/integration-test.properties | 9 ++++-- 4 files changed, 38 insertions(+), 25 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/443f20ae/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/CEPHAModeTestCase.java ---------------------------------------------------------------------- diff --git a/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/CEPHAModeTestCase.java b/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/CEPHAModeTestCase.java index dfaad23..18b8152 100644 --- a/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/CEPHAModeTestCase.java +++ b/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/CEPHAModeTestCase.java @@ -18,6 +18,7 @@ */ package org.apache.stratos.python.cartridge.agent.integration.tests; +import org.apache.commons.io.IOUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.stratos.common.domain.LoadBalancingIPType; @@ -44,22 +45,19 @@ import java.util.Properties; public class CEPHAModeTestCase extends PythonAgentIntegrationTest { - public CEPHAModeTestCase() throws IOException { - } - private static final Log log = LogFactory.getLog(CEPHAModeTestCase.class); private static final int STARTUP_TIMEOUT = 5 * 60000; - private static final String CLUSTER_ID = "php.php.domain"; + private static final String CLUSTER_ID = "tomcat.tomcat.domain"; private static final String DEPLOYMENT_POLICY_NAME = "deployment-policy-1"; private static final String AUTOSCALING_POLICY_NAME = "autoscaling-policy-1"; private static final String APP_ID = "application-1"; - private static final String MEMBER_ID = "php.member-1"; + private static final String MEMBER_ID = "tomcat.member-1"; private static final String INSTANCE_ID = "instance-1"; private static final String CLUSTER_INSTANCE_ID = "cluster-1-instance-1"; private static final String NETWORK_PARTITION_ID = "network-partition-1"; private static final String PARTITION_ID = "partition-1"; private static final String TENANT_ID = "-1234"; - private static final String SERVICE_NAME = "php"; + private static final String SERVICE_NAME = "tomcat"; private boolean startupTestCompleted = false; private Topology topology = createTestTopology(); private static final int ADC_TIMEOUT = 300000; @@ -67,11 +65,21 @@ public class CEPHAModeTestCase extends PythonAgentIntegrationTest { private boolean thriftTestCompletedinServerTwo = false; private boolean thriftTestCompletedinServerOne = false; private boolean failDetected = false; + public static final String CEP_SERVER_TWO_PORT = "cep.server.two.port"; + private int cepServerTwoPort; + + public CEPHAModeTestCase() throws IOException { + + integrationProperties + .load(PythonAgentIntegrationTest.class.getResourceAsStream(PATH_SEP + "integration-test.properties")); + cepServerTwoPort = Integer.parseInt(integrationProperties.getProperty(CEP_SERVER_TWO_PORT)); + + } @BeforeMethod(alwaysRun = true) - public void setupADCExtensionTest() throws Exception { - log.info("Setting up ADCExtensionTestCase"); + public void setupCEPHAModeTest() throws Exception { + log.info("Setting up CEPHAModeTestCase"); // Set jndi.properties.dir system property for initializing event publishers and receivers System.setProperty("jndi.properties.dir", getCommonResourcesPath()); @@ -83,17 +91,14 @@ public class CEPHAModeTestCase extends PythonAgentIntegrationTest { File file = new File(getResourcesPath() + PATH_SEP + "common" + PATH_SEP + "stratos-health-stream-def.json"); FileInputStream fis = new FileInputStream(file); - byte[] data = new byte[(int) file.length()]; - fis.read(data); - fis.close(); + String str = IOUtils.toString(fis, "UTF-8"); - String str = new String(data, "UTF-8"); if (str.equals("")) { log.warn("Stream definition of health stat stream is empty. Thrift server will not function properly"); } secondThriftTestServer.addStreamDefinition(str, Integer.parseInt(TENANT_ID)); // start with non-ssl port; test server will automatically bind to ssl port - secondThriftTestServer.start(cepPort + 1); + secondThriftTestServer.start(cepServerTwoPort); log.info("Started Thrift server with stream definition: " + str); // Simulate server socket @@ -158,6 +163,7 @@ public class CEPHAModeTestCase extends PythonAgentIntegrationTest { if (line.contains("Couldn't publish health statistics to CEP. Thrift Receiver offline.")) { failDetected = true; + log.info("Fail detected in the stopped cep server."); } } @@ -233,6 +239,7 @@ public class CEPHAModeTestCase extends PythonAgentIntegrationTest { // if the list contains an event that means PCA was able to successfully publish health stats if (eventList.size() > 0) { thriftTestCompletedinServerOne = true; + log.info("Health stats received for thirft server one"); } } }); @@ -257,6 +264,7 @@ public class CEPHAModeTestCase extends PythonAgentIntegrationTest { // if the list contains an event that means PCA was able to successfully publish health stats if (eventList.size() > 0) { thriftTestCompletedinServerTwo = true; + log.info("Health stats received for thirft server two"); } } }); http://git-wip-us.apache.org/repos/asf/stratos/blob/443f20ae/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/PythonAgentIntegrationTest.java ---------------------------------------------------------------------- diff --git a/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/PythonAgentIntegrationTest.java b/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/PythonAgentIntegrationTest.java index d441c1e..3c7661b 100644 --- a/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/PythonAgentIntegrationTest.java +++ b/products/python-cartridge-agent/modules/integration/test-integration/src/test/java/org/apache/stratos/python/cartridge/agent/integration/tests/PythonAgentIntegrationTest.java @@ -38,6 +38,7 @@ import org.apache.stratos.messaging.message.receiver.instance.status.InstanceSta import org.apache.stratos.messaging.message.receiver.topology.TopologyEventReceiver; import org.apache.stratos.messaging.util.MessagingUtil; import org.apache.stratos.python.cartridge.agent.integration.common.ThriftTestServer; +import org.apache.commons.io.IOUtils; import java.io.*; import java.net.ServerSocket; @@ -56,9 +57,10 @@ public class PythonAgentIntegrationTest { public static final String NEW_LINE = System.getProperty("line.separator"); public static final String ACTIVEMQ_AMQP_BIND_ADDRESS = "activemq.amqp.bind.address"; public static final String ACTIVEMQ_MQTT_BIND_ADDRESS = "activemq.mqtt.bind.address"; - public static final String CEP_PORT = "cep.port"; - public static final String CEP_SSL_PORT = "cep.ssl.port"; + public static final String CEP_PORT = "cep.server.one.port"; + public static final String CEP_SSL_PORT = "cep.server.one.ssl.port"; public static final String DISTRIBUTION_NAME = "distribution.name"; + public static final String TEST_THREAD_POOL_SIZE = "test.thread.pool.size"; protected final UUID PYTHON_AGENT_DIR_NAME = UUID.randomUUID(); protected Map<Integer, ServerSocket> serverSocketMap = new HashMap<>(); @@ -69,6 +71,7 @@ public class PythonAgentIntegrationTest { protected String amqpBindAddress; protected String mqttBindAddress; protected String distributionName; + protected int testThreadPoolSize; protected boolean eventReceiverInitiated = false; protected TopologyEventReceiver topologyEventReceiver; @@ -87,7 +90,7 @@ public class PythonAgentIntegrationTest { startBroker(); if (!this.eventReceiverInitiated) { - ExecutorService executorService = StratosThreadPool.getExecutorService("TEST_THREAD_POOL", 15); + ExecutorService executorService = StratosThreadPool.getExecutorService("TEST_THREAD_POOL", testThreadPoolSize); topologyEventReceiver = new TopologyEventReceiver(); topologyEventReceiver.setExecutorService(executorService); topologyEventReceiver.execute(); @@ -126,10 +129,8 @@ public class PythonAgentIntegrationTest { File file = new File(getResourcesPath() + PATH_SEP + "common" + PATH_SEP + "stratos-health-stream-def.json"); FileInputStream fis = new FileInputStream(file); - byte[] data = new byte[(int) file.length()]; - fis.read(data); - fis.close(); - String str = new String(data, "UTF-8"); + String str = IOUtils.toString(fis, "UTF-8"); + if (str.equals("")) { log.warn("Stream definition of health stat stream is empty. Thrift server will not function properly"); } @@ -210,6 +211,7 @@ public class PythonAgentIntegrationTest { mqttBindAddress = integrationProperties.getProperty(ACTIVEMQ_MQTT_BIND_ADDRESS); cepPort = Integer.parseInt(integrationProperties.getProperty(CEP_PORT)); cepSSLPort = Integer.parseInt(integrationProperties.getProperty(CEP_SSL_PORT)); + testThreadPoolSize = Integer.parseInt(integrationProperties.getProperty(TEST_THREAD_POOL_SIZE)); log.info("PCA integration properties: " + integrationProperties.toString()); } @@ -223,7 +225,7 @@ public class PythonAgentIntegrationTest { AuthenticationUser authenticationUser = new AuthenticationUser("system", "manager", "users,admins"); List<AuthenticationUser> authUserList = new ArrayList<>(); authUserList.add(authenticationUser); - broker.setPlugins(new BrokerPlugin[] { new SimpleAuthenticationPlugin(authUserList) }); + broker.setPlugins(new BrokerPlugin[]{new SimpleAuthenticationPlugin(authUserList)}); broker.setBrokerName("testBroker"); broker.setDataDirectory( PythonAgentIntegrationTest.class.getResource(PATH_SEP).getPath() + PATH_SEP + ".." + PATH_SEP + http://git-wip-us.apache.org/repos/asf/stratos/blob/443f20ae/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/CEPHAModeTestCase/payload/launch-params ---------------------------------------------------------------------- diff --git a/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/CEPHAModeTestCase/payload/launch-params b/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/CEPHAModeTestCase/payload/launch-params index 1b44343..4a97c82 100755 --- a/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/CEPHAModeTestCase/payload/launch-params +++ b/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/CEPHAModeTestCase/payload/launch-params @@ -1 +1 @@ -APPLICATION_ID=application-1,APPLICATION_PATH=/tmp/AgentStartupTestCase,BASH=/bin/bash,BASHOPTS=cmdhist:complete_fullquote:extquote:force_fignore:hostcomplete:interactive_comments:progcomp:promptvars:sourcepath,BASH_ALIASES=(),BASH_ARGC=(),BASH_ARGV=(),BASH_CMDS=(),BASH_LINENO=([0]="0"),BASH_SOURCE=([0]="/usr/local/bin/populate-user-data.sh"),BASH_VERSINFO=([0]="4" [1]="3" [2]="30" [3]="1" [4]="release" [5]="x86_64-pc-linux-gnu"),BASH_VERSION='4.3.30(1)-release',CARTRIDGE_ALIAS=mytomcat,CARTRIDGE_KEY=PUjpXCLujDhYr5A6,CATALINA_HOME=/opt/tomcat,CEP_IP=54.179.197.243,CEP_PORT=7711,CLUSTER_ID=php.php.domain,CLUSTER_INSTANCE_ID=cluster-1-instance-1,DEPENDENCY_CLUSTER_IDS=myphp.php.domain,DEPLOYMENT=default,DIRSTACK=(),EUID=0,GROUPS=(),GROUP_NAME=null,HOME=/root,HOSTNAME=mytomcat-tomcat-domain3bd3cd47-b95d-475a-aa11-3e3ddc089d49,HOSTTYPE=x86_64,HOST_NAME=mytomcat.tomcat.stratos.org,IFS=' ,',INSTANCE_ID=null,INTERNAL=false,JAVA_HOME=/opt/jdk1.7.0_67,KUBERNETES_CLUSTER_ID=kubernetes-cluste r-1,KUBERNETES_PORT=tcp://10.100.0.2:443,KUBERNETES_PORT_443_TCP=tcp://10.100.0.2:443,KUBERNETES_PORT_443_TCP_ADDR=10.100.0.2,KUBERNETES_PORT_443_TCP_PORT=443,KUBERNETES_PORT_443_TCP_PROTO=tcp,KUBERNETES_RO_PORT=tcp://10.100.0.1:80,KUBERNETES_RO_PORT_80_TCP=tcp://10.100.0.1:80,KUBERNETES_RO_PORT_80_TCP_ADDR=10.100.0.1,KUBERNETES_RO_PORT_80_TCP_PORT=80,KUBERNETES_RO_PORT_80_TCP_PROTO=tcp,KUBERNETES_RO_SERVICE_HOST=10.100.0.1,KUBERNETES_RO_SERVICE_PORT=80,KUBERNETES_SERVICE_HOST=10.100.0.2,KUBERNETES_SERVICE_PORT=443,LB_CLUSTER_ID=null,LOG_LEVEL=DEBUG,MACHTYPE=x86_64-pc-linux-gnu,MB_IP=54.179.197.243,MB_PORT=1883,MEMBER_ID=php.member-1,MIN_COUNT=1,MULTITENANT=false,MYPHP_PHP_DOMAIN_1_PORT=tcp://10.100.171.218:4500,MYPHP_PHP_DOMAIN_1_PORT_4500_TCP=tcp://10.100.171.218:4500,MYPHP_PHP_DOMAIN_1_PORT_4500_TCP_ADDR=10.100.171.218,MYPHP_PHP_DOMAIN_1_PORT_4500_TCP_PORT=4500,MYPHP_PHP_DOMAIN_1_PORT_4500_TCP_PROTO=tcp,MYPHP_PHP_DOMAIN_1_SERVICE_HOST=10.100.171.218,MYPHP_PHP_DOMAIN_1_SERVICE_POR T=4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT=tcp://10.100.16.250:4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP=tcp://10.100.16.250:4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_ADDR=10.100.16.250,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_PORT=4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_PROTO=tcp,MYTOMCAT_TOMCAT_DOMAIN_1_SERVICE_HOST=10.100.16.250,MYTOMCAT_TOMCAT_DOMAIN_1_SERVICE_PORT=4500,NETWORK_PARTITION_ID=network-partition-1,OPTERR=1,OPTIND=1,OSTYPE=linux-gnu,PARTITION_ID=partition-1,PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin,PIPESTATUS=([0]="0"),PORTS=8080,POSIXLY_CORRECT=y,PPID=14,PRIMARY=false,PROVIDER=apache,PS4='+ ',PUPPET_DNS_AVAILABLE=null,PUPPET_ENV=false,PUPPET_HOSTNAME=puppet.apache.stratos.org,PUPPET_IP=127.0.0.1,PWD=/opt,SERVICE_NAME=php,SHELL=/bin/bash,SHELLOPTS=braceexpand:hashall:interactive-comments:posix,SHLVL=2,TENANT_ID=-1234,TENANT_RANGE='*',TERM=dumb,TOKEN=eyJhbGciOiJSUzI1NiJ9.eyJleHAiOi04NzI0ODEyNDEsInN1YiI6ImFkbWluIiwiYXpwIjoid3I5SllVaDNtTXd6bVhHVl lqWmVIWnhCV2xFYSIsImFwcElkIjoic2luZ2xlX2dyb3VwX3YxIiwiYXVkIjpbIndyOUpZVWgzbU13em1YR1ZZalplSFp4QldsRWEiXSwiaXNzIjoiaHR0cHM6XC9cL2xvY2FsaG9zdDo5NDQzXC9vYXV0aDJlbmRwb2ludHNcL3Rva2VuIiwiaWF0IjotODcyNDgwMjQwfQ.OSa1gIXUT9amhk1YEU02Yc3JtUYqanzrXh5K1YyvRXcpSiY2Ccn2BfJO0hILF5UooRcGBihzfX3979NRcvGwcUDUvOUJ0eaGPmxFZYbu0nr3xD8lhAO3fa1QYsKAvMnMdwyu2uSgSp6R6EUdVleiwlabUoDsuEcKGkIAn_VQvG0,UID=0,_=posix,LVS_VIRTUAL_IP=192.168.0.40|255.255.255.0 \ No newline at end of file +APPLICATION_ID=application-1,APPLICATION_PATH=/tmp/CEPHAModeTestCase,BASH=/bin/bash,BASHOPTS=cmdhist:complete_fullquote:extquote:force_fignore:hostcomplete:interactive_comments:progcomp:promptvars:sourcepath,BASH_ALIASES=(),BASH_ARGC=(),BASH_ARGV=(),BASH_CMDS=(),BASH_LINENO=([0]="0"),BASH_SOURCE=([0]="/usr/local/bin/populate-user-data.sh"),BASH_VERSINFO=([0]="4" [1]="3" [2]="30" [3]="1" [4]="release" [5]="x86_64-pc-linux-gnu"),BASH_VERSION='4.3.30(1)-release',CARTRIDGE_ALIAS=mytomcat,CARTRIDGE_KEY=PUjpXCLujDhYr5A6,CATALINA_HOME=/opt/tomcat,CEP_IP=54.179.197.243,CEP_PORT=7711,CLUSTER_ID=tomcat.tomcat.domain,CLUSTER_INSTANCE_ID=cluster-1-instance-1,DEPENDENCY_CLUSTER_IDS=mytomcat.tomcat.domain,DEPLOYMENT=default,DIRSTACK=(),EUID=0,GROUPS=(),GROUP_NAME=null,HOME=/root,HOSTNAME=mytomcat-tomcat-domain3bd3cd47-b95d-475a-aa11-3e3ddc089d49,HOSTTYPE=x86_64,HOST_NAME=mytomcat.tomcat.stratos.org,IFS=' ,',INSTANCE_ID=null,INTERNAL=false,JAVA_HOME=/opt/jdk1.7.0_67,KUBERNETES_CLUSTER_ID=kubernet es-cluster-1,KUBERNETES_PORT=tcp://10.100.0.2:443,KUBERNETES_PORT_443_TCP=tcp://10.100.0.2:443,KUBERNETES_PORT_443_TCP_ADDR=10.100.0.2,KUBERNETES_PORT_443_TCP_PORT=443,KUBERNETES_PORT_443_TCP_PROTO=tcp,KUBERNETES_RO_PORT=tcp://10.100.0.1:80,KUBERNETES_RO_PORT_80_TCP=tcp://10.100.0.1:80,KUBERNETES_RO_PORT_80_TCP_ADDR=10.100.0.1,KUBERNETES_RO_PORT_80_TCP_PORT=80,KUBERNETES_RO_PORT_80_TCP_PROTO=tcp,KUBERNETES_RO_SERVICE_HOST=10.100.0.1,KUBERNETES_RO_SERVICE_PORT=80,KUBERNETES_SERVICE_HOST=10.100.0.2,KUBERNETES_SERVICE_PORT=443,LB_CLUSTER_ID=null,LOG_LEVEL=DEBUG,MACHTYPE=x86_64-pc-linux-gnu,MB_IP=54.179.197.243,MB_PORT=1883,MEMBER_ID=tomcat.member-1,MIN_COUNT=1,MULTITENANT=false,MYTOMCAT_TOMCAT_DOMAIN_1_PORT=tcp://10.100.171.218:4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP=tcp://10.100.171.218:4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_ADDR=10.100.171.218,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_PORT=4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_PROTO=tcp,MYTOMCAT_TOMCAT_DOMAIN_1_SERVICE_HO ST=10.100.171.218,MYTOMCAT_TOMCAT_DOMAIN_1_SERVICE_PORT=4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT=tcp://10.100.16.250:4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP=tcp://10.100.16.250:4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_ADDR=10.100.16.250,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_PORT=4500,MYTOMCAT_TOMCAT_DOMAIN_1_PORT_4500_TCP_PROTO=tcp,MYTOMCAT_TOMCAT_DOMAIN_1_SERVICE_HOST=10.100.16.250,MYTOMCAT_TOMCAT_DOMAIN_1_SERVICE_PORT=4500,NETWORK_PARTITION_ID=network-partition-1,OPTERR=1,OPTIND=1,OSTYPE=linux-gnu,PARTITION_ID=partition-1,PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin,PIPESTATUS=([0]="0"),PORTS=8080,POSIXLY_CORRECT=y,PPID=14,PRIMARY=false,PROVIDER=apache,PS4='+ ',PUPPET_DNS_AVAILABLE=null,PUPPET_ENV=false,PUPPET_HOSTNAME=puppet.apache.stratos.org,PUPPET_IP=127.0.0.1,PWD=/opt,SERVICE_NAME=tomcat,SHELL=/bin/bash,SHELLOPTS=braceexpand:hashall:interactive-comments:posix,SHLVL=2,TENANT_ID=-1234,TENANT_RANGE='*',TERM=dumb,TOKEN=eyJhbGciOiJSUzI1NiJ9.eyJleHAiOi04NzI0O DEyNDEsInN1YiI6ImFkbWluIiwiYXpwIjoid3I5SllVaDNtTXd6bVhHVllqWmVIWnhCV2xFYSIsImFwcElkIjoic2luZ2xlX2dyb3VwX3YxIiwiYXVkIjpbIndyOUpZVWgzbU13em1YR1ZZalplSFp4QldsRWEiXSwiaXNzIjoiaHR0cHM6XC9cL2xvY2FsaG9zdDo5NDQzXC9vYXV0aDJlbmRwb2ludHNcL3Rva2VuIiwiaWF0IjotODcyNDgwMjQwfQ.OSa1gIXUT9amhk1YEU02Yc3JtUYqanzrXh5K1YyvRXcpSiY2Ccn2BfJO0hILF5UooRcGBihzfX3979NRcvGwcUDUvOUJ0eaGPmxFZYbu0nr3xD8lhAO3fa1QYsKAvMnMdwyu2uSgSp6R6EUdVleiwlabUoDsuEcKGkIAn_VQvG0,UID=0,_=posix,LVS_VIRTUAL_IP=192.168.0.40|255.255.255.0 \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/443f20ae/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/test-conf/integration-test.properties ---------------------------------------------------------------------- diff --git a/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/test-conf/integration-test.properties b/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/test-conf/integration-test.properties index 332441a..5a98dbe 100755 --- a/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/test-conf/integration-test.properties +++ b/products/python-cartridge-agent/modules/integration/test-integration/src/test/resources/test-conf/integration-test.properties @@ -20,8 +20,11 @@ distribution.version=${project.version} distribution.name=${python.cartridge.agent.distribution.name}-${project.version} activemq.amqp.bind.address=tcp://localhost:61617 activemq.mqtt.bind.address=mqtt://localhost:1885 -cep.port=7612 -cep.ssl.port=7712 +cep.server.one.port=7612 +cep.server.two.port=7613 +cep.server.one.ssl.port=7712 +cep.server.two.ssl.port=7713 stratos.endpoint=http://localhost:9763 stratos.admin.username=admin -stratos.admin.password=admin \ No newline at end of file +stratos.admin.password=admin +test.thread.pool.size=20 \ No newline at end of file
