brooklyn-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From henev...@apache.org
Subject [32/50] brooklyn-server git commit: Adds HttpSensorAdapterTest.testReportsErrorOnFailedConnection
Date Mon, 01 Feb 2016 17:49:02 GMT
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 <aled.sage@gmail.com>
Authored: Wed Oct 10 21:34:02 2012 +0100
Committer: Aled Sage <aled.sage@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();
+        }
+    }
 }


Mime
View raw message