Lines Matching refs:consumer
47 testIncluded(Consumer consumer, String ... aggregationNames)
63 aggregate = consumer.getAggregate(included, null);
81 if (!consumer.isRunning()) {
82 throw new IllegalStateException("consumer exited");
87 testCleared(Consumer consumer, String ... aggregationNames)
104 aggregate = consumer.getAggregate(null, cleared);
110 aggregate = consumer.getAggregate(null, cleared);
119 } while (consumer.isRunning() && n++ < INTERVALS);
146 if (!consumer.isRunning()) {
147 throw new IllegalStateException("consumer exited");
157 final Consumer consumer = new LocalConsumer();
158 consumer.addConsumerListener(new ConsumerAdapter() {
163 testIncluded(consumer, ANONYMOUS_AGGREGATION);
169 consumer.abort();
177 consumer.open();
178 consumer.setOption(Option.aggrate, Option.millis(TICK));
179 consumer.compile(programString);
180 consumer.enable();
181 consumer.go();
191 final Consumer consumer = new LocalConsumer();
192 consumer.addConsumerListener(new ConsumerAdapter() {
197 testCleared(consumer, ANONYMOUS_AGGREGATION);
203 consumer.abort();
211 consumer.open();
212 consumer.setOption(Option.aggrate, Option.millis(TICK));
213 consumer.compile(programString);
214 consumer.enable();
215 consumer.go();