@Test(groups="Integration") public void testStartSuspended() throws Exception { feed = HttpFeed.builder() .entity(entity) .baseUrl(baseUrl) .poll(HttpPollConfig.forSensor(SENSOR_INT) .period(100) .onSuccess(HttpValueFunctions.responseCode())) .poll(HttpPollConfig.forSensor(SENSOR_STRING) .period(100) .onSuccess(HttpValueFunctions.stringContentsFunction())) .suspended() .build(); Asserts.continually(MutableMap.of("timeout", 500), Entities.attributeSupplier(entity, SENSOR_INT), Predicates.<Integer>equalTo(null)); int countWhenSuspended = server.getRequestCount(); feed.resume(); Asserts.eventually(Entities.attributeSupplier(entity, SENSOR_INT), Predicates.<Integer>equalTo(200)); if (server.getRequestCount() <= countWhenSuspended) Assert.fail("Request count failed to increment when feed was resumed, from "+countWhenSuspended+", still at "+server.getRequestCount()); log.info("RUN: "+countWhenSuspended+" - "+server.getRequestCount()); }
public static Builder builder() { return new Builder(); }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } HttpFeed(); protected  HttpFeed(Builder builder); }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } HttpFeed(); protected  HttpFeed(Builder builder); static Builder builder(); }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } HttpFeed(); protected  HttpFeed(Builder builder); static Builder builder(); static final Logger log; @SuppressWarnings("serial")
    static final ConfigKey<SetMultimap<HttpPollIdentifier, HttpPollConfig<?>>> POLLS; }