@Test public void testAddToKafkaEventGetTimer() throws Exception { Assert.assertEquals(1L, counter.addToKafkaEventGetTimer(1L)); }
public long addToKafkaEventGetTimer(long delta) { return addAndGet(TIMER_KAFKA_EVENT_GET,delta); }
KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean { public long addToKafkaEventGetTimer(long delta) { return addAndGet(TIMER_KAFKA_EVENT_GET,delta); } }
KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean { public long addToKafkaEventGetTimer(long delta) { return addAndGet(TIMER_KAFKA_EVENT_GET,delta); } KafkaSourceCounter(String name); }
KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean { public long addToKafkaEventGetTimer(long delta) { return addAndGet(TIMER_KAFKA_EVENT_GET,delta); } KafkaSourceCounter(String name); long addToKafkaEventGetTimer(long delta); long addToKafkaCommitTimer(long delta); long incrementKafkaEmptyCount(); long getKafkaCommitTimer(); long getKafkaEventGetTimer(); long getKafkaEmptyCount(); }
KafkaSourceCounter extends SourceCounter implements  KafkaSourceCounterMBean { public long addToKafkaEventGetTimer(long delta) { return addAndGet(TIMER_KAFKA_EVENT_GET,delta); } KafkaSourceCounter(String name); long addToKafkaEventGetTimer(long delta); long addToKafkaCommitTimer(long delta); long incrementKafkaEmptyCount(); long getKafkaCommitTimer(); long getKafkaEventGetTimer(); long getKafkaEmptyCount();  }