test_class.declarator: catcher
test_class.original_string: MetricsCatcher<?> catcher;
test_class.type: MetricsCatcher<?>
test_class.var_name: catcher
test_class.declarator: registry
test_class.original_string: MetricRegistry registry;
test_class.type: MetricRegistry
test_class.var_name: registry
test_class.declarator: bus
test_class.original_string: EventBus bus;
test_class.type: EventBus
test_class.var_name: bus
test_class.declarator: config
test_class.original_string: Configuration config;
test_class.type: Configuration
test_class.var_name: config
test_class.file: micro-event-metrics/src/test/java/com/oath/micro/server/event/metrics/MetricsCatcherTest.java
test_class.identifier: MetricsCatcherTest
test_case.body: @Test
      public void jobsCounterDec() {
  
          catcher.jobComplete(new JobCompleteEvent("10", "test", 10l, 5l));
          assertThat(registry.counter(this.config.getPrefix() + ".jobs-active-test-count")
                             .getCount(),
                     equalTo(-1l));
      }
test_case.class_method_signature: MetricsCatcherTest.jobsCounterDec()
test_case.full_signature: @Test public void jobsCounterDec()
test_case.identifier: jobsCounterDec
test_case.invocations: jobComplete assertThat getCount counter getPrefix equalTo
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void jobsCounterDec()
focal_class.declarator: registry
focal_class.modifier: private final
focal_class.original_string: private final MetricRegistry registry;
focal_class.type: MetricRegistry
focal_class.var_name: registry
focal_class.declarator: queries
focal_class.modifier: private final
focal_class.original_string: private final TimerManager queries;
focal_class.type: TimerManager
focal_class.var_name: queries
focal_class.declarator: jobs
focal_class.modifier: private final
focal_class.original_string: private final TimerManager jobs;
focal_class.type: TimerManager
focal_class.var_name: jobs
focal_class.declarator: configuration
focal_class.modifier: private final
focal_class.original_string: private final Configuration configuration;
focal_class.type: Configuration
focal_class.var_name: configuration
focal_class.declarator: prefix
focal_class.modifier: private final
focal_class.original_string: private final String prefix;
focal_class.type: String
focal_class.var_name: prefix
focal_class.file: micro-event-metrics/src/main/java/com/oath/micro/server/event/metrics/MetricsCatcher.java
focal_class.identifier: MetricsCatcher
focal_class.class_method_signature: MetricsCatcher.MetricsCatcher(MetricRegistry registry, EventBus bus, Configuration configuration)
focal_class.full_signature: @Autowired public  MetricsCatcher(MetricRegistry registry, EventBus bus, Configuration configuration)
focal_class.identifier: MetricsCatcher
focal_class.modifiers: @Autowired public
focal_class.parameters: (MetricRegistry registry, EventBus bus, Configuration configuration)
focal_class.signature:  MetricsCatcher(MetricRegistry registry, EventBus bus, Configuration configuration)
focal_class.class_method_signature: MetricsCatcher.requestStart(AddQuery<T> data)
focal_class.full_signature: @Subscribe public void requestStart(AddQuery<T> data)
focal_class.identifier: requestStart
focal_class.modifiers: @Subscribe public
focal_class.parameters: (AddQuery<T> data)
focal_class.return: void
focal_class.signature: void requestStart(AddQuery<T> data)
focal_class.class_method_signature: MetricsCatcher.queryStartName(RequestData<T> rd)
focal_class.full_signature: private String queryStartName(RequestData<T> rd)
focal_class.identifier: queryStartName
focal_class.modifiers: private
focal_class.parameters: (RequestData<T> rd)
focal_class.return: String
focal_class.signature: String queryStartName(RequestData<T> rd)
focal_class.class_method_signature: MetricsCatcher.queryEndName(RequestData<T> rd)
focal_class.full_signature: private String queryEndName(RequestData<T> rd)
focal_class.identifier: queryEndName
focal_class.modifiers: private
focal_class.parameters: (RequestData<T> rd)
focal_class.return: String
focal_class.signature: String queryEndName(RequestData<T> rd)
focal_class.class_method_signature: MetricsCatcher.requestComplete(RemoveQuery<T> data)
focal_class.full_signature: @Subscribe public void requestComplete(RemoveQuery<T> data)
focal_class.identifier: requestComplete
focal_class.modifiers: @Subscribe public
focal_class.parameters: (RemoveQuery<T> data)
focal_class.return: void
focal_class.signature: void requestComplete(RemoveQuery<T> data)
focal_class.class_method_signature: MetricsCatcher.requestStart(AddLabelledQuery<T> data)
focal_class.full_signature: @Subscribe public void requestStart(AddLabelledQuery<T> data)
focal_class.identifier: requestStart
focal_class.modifiers: @Subscribe public
focal_class.parameters: (AddLabelledQuery<T> data)
focal_class.return: void
focal_class.signature: void requestStart(AddLabelledQuery<T> data)
focal_class.class_method_signature: MetricsCatcher.requestComplete(RemoveLabelledQuery<T> data)
focal_class.full_signature: @Subscribe public void requestComplete(RemoveLabelledQuery<T> data)
focal_class.identifier: requestComplete
focal_class.modifiers: @Subscribe public
focal_class.parameters: (RemoveLabelledQuery<T> data)
focal_class.return: void
focal_class.signature: void requestComplete(RemoveLabelledQuery<T> data)
focal_class.class_method_signature: MetricsCatcher.finished(SystemData data)
focal_class.full_signature: @Subscribe public void finished(SystemData data)
focal_class.identifier: finished
focal_class.modifiers: @Subscribe public
focal_class.parameters: (SystemData data)
focal_class.return: void
focal_class.signature: void finished(SystemData data)
focal_class.class_method_signature: MetricsCatcher.jobStarted(JobStartEvent data)
focal_class.full_signature: @Subscribe public void jobStarted(JobStartEvent data)
focal_class.identifier: jobStarted
focal_class.modifiers: @Subscribe public
focal_class.parameters: (JobStartEvent data)
focal_class.return: void
focal_class.signature: void jobStarted(JobStartEvent data)
focal_class.class_method_signature: MetricsCatcher.jobComplete(JobCompleteEvent data)
focal_class.full_signature: @Subscribe public void jobComplete(JobCompleteEvent data)
focal_class.identifier: jobComplete
focal_class.modifiers: @Subscribe public
focal_class.parameters: (JobCompleteEvent data)
focal_class.return: void
focal_class.signature: void jobComplete(JobCompleteEvent data)
focal_class.class_method_signature: MetricsCatcher.error(ErrorCode c)
focal_class.full_signature: @Subscribe public void error(ErrorCode c)
focal_class.identifier: error
focal_class.modifiers: @Subscribe public
focal_class.parameters: (ErrorCode c)
focal_class.return: void
focal_class.signature: void error(ErrorCode c)
focal_class.class_method_signature: MetricsCatcher.error(ErrorEvent event)
focal_class.full_signature: @Subscribe public void error(ErrorEvent event)
focal_class.identifier: error
focal_class.modifiers: @Subscribe public
focal_class.parameters: (ErrorEvent event)
focal_class.return: void
focal_class.signature: void error(ErrorEvent event)
focal_class.class_method_signature: MetricsCatcher.genericEvent(GenericEvent event)
focal_class.full_signature: @Subscribe public void genericEvent(GenericEvent event)
focal_class.identifier: genericEvent
focal_class.modifiers: @Subscribe public
focal_class.parameters: (GenericEvent event)
focal_class.return: void
focal_class.signature: void genericEvent(GenericEvent event)
focal_class.class_method_signature: MetricsCatcher.name(ErrorCode c)
focal_class.full_signature: private String name(ErrorCode c)
focal_class.identifier: name
focal_class.modifiers: private
focal_class.parameters: (ErrorCode c)
focal_class.return: String
focal_class.signature: String name(ErrorCode c)
focal_class.class_method_signature: MetricsCatcher.timer(String name)
focal_class.full_signature: private Timer timer(String name)
focal_class.identifier: timer
focal_class.modifiers: private
focal_class.parameters: (String name)
focal_class.return: Timer
focal_class.signature: Timer timer(String name)
focal_method.body: @Subscribe
      public void jobComplete(JobCompleteEvent data) {
          if (this.configuration.isJobsByType()) {
              jobs.complete(data.getCorrelationId());
              registry.counter(prefix + ".jobs-active-" + data.getType() + "-count")
                      .dec();
  
              registry.counter(prefix + ".jobs-processed-" + data.getType() + "-count-data")
                      .inc(data.getDataSize());
              registry.meter(prefix + ".jobs-processed-" + data.getType() + "-meter-data")
                      .mark(data.getDataSize());
              registry.counter(prefix + ".jobs-errors-" + data.getType() + "-count-data")
                      .inc(data.getErrors());
              registry.meter(prefix + ".jobs-errors-" + data.getType() + "-meter-data")
                      .mark(data.getErrors());
  
              if (data.getErrors() > 0l) {
                  registry.counter(prefix + ".jobs-succeeded-" + data.getType() + "-count")
                          .inc();
                  registry.meter(prefix + ".jobs-succeeded-" + data.getType() + "-meter")
                          .mark();
  
              } else {
  
                  registry.counter(prefix + ".jobs-failed-" + data.getType() + "-count")
                          .inc();
                  registry.meter(prefix + ".jobs-failed-" + data.getType() + "-meter")
                          .mark();
              }
          }
      }
focal_method.class_method_signature: MetricsCatcher.jobComplete(JobCompleteEvent data)
focal_method.full_signature: @Subscribe public void jobComplete(JobCompleteEvent data)
focal_method.identifier: jobComplete
focal_method.invocations: isJobsByType complete getCorrelationId dec counter getType inc counter getType getDataSize mark meter getType getDataSize inc counter getType getErrors mark meter getType getErrors getErrors inc counter getType mark meter getType inc counter getType mark meter getType
focal_method.modifiers: @Subscribe public
focal_method.parameters: (JobCompleteEvent data)
focal_method.return: void
focal_method.signature: void jobComplete(JobCompleteEvent data)