You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@brooklyn.apache.org by he...@apache.org on 2016/02/01 18:49:02 UTC
[32/50] brooklyn-server git commit: Adds
HttpSensorAdapterTest.testReportsErrorOnFailedConnection
Adds HttpSensorAdapterTest.testReportsErrorOnFailedConnection
Project: http://git-wip-us.apache.org/repos/asf/brooklyn-server/repo
Commit: http://git-wip-us.apache.org/repos/asf/brooklyn-server/commit/0b2a3fa2
Tree: http://git-wip-us.apache.org/repos/asf/brooklyn-server/tree/0b2a3fa2
Diff: http://git-wip-us.apache.org/repos/asf/brooklyn-server/diff/0b2a3fa2
Branch: refs/heads/0.4.0
Commit: 0b2a3fa2c557e5aa288d82b3b84df9b46d5a5699
Parents: 03f0209
Author: Aled Sage <al...@gmail.com>
Authored: Wed Oct 10 21:34:02 2012 +0100
Committer: Aled Sage <al...@gmail.com>
Committed: Thu Oct 11 10:05:46 2012 +0100
----------------------------------------------------------------------
.../event/adapter/HttpSensorAdapterTest.groovy | 47 ++++++++++++++++----
1 file changed, 39 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/brooklyn-server/blob/0b2a3fa2/core/src/test/java/brooklyn/event/adapter/HttpSensorAdapterTest.groovy
----------------------------------------------------------------------
diff --git a/core/src/test/java/brooklyn/event/adapter/HttpSensorAdapterTest.groovy b/core/src/test/java/brooklyn/event/adapter/HttpSensorAdapterTest.groovy
index d426092..1163b57 100644
--- a/core/src/test/java/brooklyn/event/adapter/HttpSensorAdapterTest.groovy
+++ b/core/src/test/java/brooklyn/event/adapter/HttpSensorAdapterTest.groovy
@@ -4,10 +4,14 @@ import static brooklyn.event.adapter.HttpResponseContextTest.*
import static org.codehaus.groovy.runtime.DefaultGroovyMethods.with
import static org.testng.Assert.*
+import org.testng.annotations.AfterMethod
+import org.testng.annotations.BeforeMethod
import org.testng.annotations.Test
import brooklyn.entity.basic.EntityLocal
import brooklyn.event.basic.BasicAttributeSensor
+import brooklyn.test.TestUtils
+import brooklyn.test.entity.TestApplication
import brooklyn.test.entity.TestEntity
public class HttpSensorAdapterTest {
@@ -16,14 +20,24 @@ public class HttpSensorAdapterTest {
final static BasicAttributeSensor SENSOR_LONG = [Long.class, "aLong", ""];
final static BasicAttributeSensor SENSOR_BOOLEAN = [Boolean.class, "aBool", ""];
- final EntityLocal entity = new TestEntity();
- final HttpSensorAdapter adapter = [ "BOGUS URL" ]
- final SensorRegistry registry = new SensorRegistry(entity);
+ TestApplication app;
+ EntityLocal entity;
+ HttpSensorAdapter adapter;
+ SensorRegistry registry;
- {
- def ad2 = registry.register(adapter)
- assertEquals(ad2, adapter)
- }
+ @BeforeMethod(alwaysRun=true)
+ public void setUp() throws Exception {
+ app = new TestApplication();
+ entity = new TestEntity(app);
+ registry = new SensorRegistry(entity);
+ adapter = registry.register(new HttpSensorAdapter("http://bogus.url.is.definitely.wrong.efaege3"))
+ }
+
+ @AfterMethod(alwaysRun=true)
+ public void tearDown() throws Exception {
+ if (registry != null) registry.close();
+ if (app != null) app.stop();
+ }
@Test
public void testContentEvaluation() {
@@ -53,5 +67,22 @@ public class HttpSensorAdapterTest {
//string in header should be be automatically converted to long
assertEquals entity.getAttribute(SENSOR_LONG), 8
}
-
+
+ // Relies on URL above being bogus
+ @Test(groups="Integration")
+ public void testReportsErrorOnFailedConnection() {
+ BasicAttributeSensor<Exception> exceptionSensor = new BasicAttributeSensor(Exception.class, "test.exception", "mydescr");
+ try {
+ adapter.poll(exceptionSensor, {error});
+ registry.activateAdapters();
+
+ TestUtils.executeUntilSucceeds {
+ Object val = entity.getAttribute(exceptionSensor);
+ assertNotNull(val);
+ assertTrue(val instanceof Exception, "val="+val);
+ }
+ } finally {
+ registry.close();
+ }
+ }
}