Package io.camunda.client.impl.worker.metrics

Class MicrometerJobWorkerMetrics

java.lang.Object
io.camunda.client.impl.worker.metrics.MicrometerJobWorkerMetrics
All Implemented Interfaces:
JobWorkerMetrics
public final class MicrometerJobWorkerMetrics extends Object implements JobWorkerMetrics

  • Constructor Summary

    Constructors
    Constructor
    Description
    MicrometerJobWorkerMetrics(io.micrometer.core.instrument.Counter jobActivatedCounter, io.micrometer.core.instrument.Counter jobHandledCounter, io.micrometer.core.instrument.Counter streamInactivityRecreatedCounter)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    jobActivated(int count)
    Called every time one or more jobs are activated.
    void
    jobHandled(int count)
    Called every time one or more jobs are handled.
    void
    streamInactivityRecreated()
    Called every time the streaming job worker recreates its stream because the configured stream inactivity timeout elapsed without any activity.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MicrometerJobWorkerMetrics

      public MicrometerJobWorkerMetrics(io.micrometer.core.instrument.Counter jobActivatedCounter, io.micrometer.core.instrument.Counter jobHandledCounter, io.micrometer.core.instrument.Counter streamInactivityRecreatedCounter)

  • Method Details

    • jobActivated

      public void jobActivated(int count)
      Description copied from interface: JobWorkerMetrics
      Called every time one or more jobs are activated.

      NOTE: this is called before the job is worked on.

      Specified by:
      jobActivated in interface JobWorkerMetrics
      Parameters:
      count - the amount of jobs that were activated

    • jobHandled

      public void jobHandled(int count)
      Description copied from interface: JobWorkerMetrics
      Called every time one or more jobs are handled.

      NOTE: this is called after a job has been worked on, successfully or not.

      Specified by:
      jobHandled in interface JobWorkerMetrics
      Parameters:
      count - the amount of jobs that were handled

    • streamInactivityRecreated

      public void streamInactivityRecreated()
      Description copied from interface: JobWorkerMetrics
      Called every time the streaming job worker recreates its stream because the configured stream inactivity timeout elapsed without any activity. Useful to monitor whether the inactivity watchdog is firing in a given deployment (e.g. due to an upstream proxy idle close), without relying on log scraping.
      Specified by:
      streamInactivityRecreated in interface JobWorkerMetrics