diff --git a/prometheus/src/main/java/com/itv/bucky/prometheus/PrometheusMetricsCollector.java b/prometheus/src/main/java/com/itv/bucky/prometheus/PrometheusMetricsCollector.java index 8e32674..a4da661 100644 --- a/prometheus/src/main/java/com/itv/bucky/prometheus/PrometheusMetricsCollector.java +++ b/prometheus/src/main/java/com/itv/bucky/prometheus/PrometheusMetricsCollector.java @@ -13,150 +13,150 @@ public class PrometheusMetricsCollector extends AbstractMetricsCollector { - private final Gauge connections; + private final Gauge connections; - private final Gauge channels; + private final Gauge channels; - private final Counter publishedMessages; + private final Counter publishedMessages; - private final Counter failedToPublishMessages; + private final Counter failedToPublishMessages; - private final Counter ackedPublishedMessages; + private final Counter ackedPublishedMessages; - private final Counter nackedPublishedMessages; + private final Counter nackedPublishedMessages; - private final Counter unroutedPublishedMessages; + private final Counter unroutedPublishedMessages; - private final Counter consumedMessages; + private final Counter consumedMessages; - private final Counter acknowledgedMessages; + private final Counter acknowledgedMessages; - private final Counter rejectedMessages; + private final Counter rejectedMessages; - public PrometheusMetricsCollector(final CollectorRegistry registry) { - this(registry, "rabbitmq"); - } + public PrometheusMetricsCollector(final CollectorRegistry registry) { + this(registry, "rabbitmq"); + } - public PrometheusMetricsCollector(final CollectorRegistry registry, final String prefix) { - this.connections = Gauge.build() + public PrometheusMetricsCollector(final CollectorRegistry registry, final String prefix) { + this.connections = Gauge.build() .name(prefix + "_connections") .help("Current connections") .create(); - registry.register(this.connections); + registry.register(this.connections); - this.channels = Gauge.build() + this.channels = Gauge.build() .name(prefix + "_channels") .help("Current channels") .create(); - registry.register(this.channels); + registry.register(this.channels); - this.publishedMessages = Counter.build() + this.publishedMessages = Counter.build() .name(prefix + "_published_messages") .help("Count of published messages") .create(); - registry.register(this.publishedMessages); + registry.register(this.publishedMessages); - this.failedToPublishMessages = Counter.build() + this.failedToPublishMessages = Counter.build() .name(prefix + "_failed_to_publish_messages") .help("Count of failed to publish messages") .create(); - registry.register(failedToPublishMessages); + registry.register(failedToPublishMessages); - this.ackedPublishedMessages = Counter.build() + this.ackedPublishedMessages = Counter.build() .name(prefix + "_acked_published_messages") .help("Count of acknowledged publish messages") .create(); - registry.register(ackedPublishedMessages); + registry.register(ackedPublishedMessages); - this.nackedPublishedMessages = Counter.build() + this.nackedPublishedMessages = Counter.build() .name(prefix + "_nacked_published_messages") .help("Count of not acknowledged publish messages") .create(); - registry.register(nackedPublishedMessages); + registry.register(nackedPublishedMessages); - this.unroutedPublishedMessages = Counter.build() + this.unroutedPublishedMessages = Counter.build() .name(prefix + "_unrouted_published_messages") .help("Count of unrouted publish messages") .create(); - registry.register(unroutedPublishedMessages); + registry.register(unroutedPublishedMessages); - this.consumedMessages = Counter.build() + this.consumedMessages = Counter.build() .name(prefix + "_consumed_messages") .help("Count of consumed messages") .create(); - registry.register(consumedMessages); + registry.register(consumedMessages); - this.acknowledgedMessages = Counter.build() + this.acknowledgedMessages = Counter.build() .name(prefix + "_acknowledged_messages") .help("Count of acknowledged consumed messages") .create(); - registry.register(acknowledgedMessages); + registry.register(acknowledgedMessages); - this.rejectedMessages = Counter.build() + this.rejectedMessages = Counter.build() .name(prefix + "_rejected_messages") .help("Count of rejected consumed messages") .create(); - registry.register(rejectedMessages); - - } - - @Override - protected void incrementConnectionCount(Connection connection) { - connections.inc(); - } - - @Override - protected void decrementConnectionCount(Connection connection) { - connections.dec(); - } - - @Override - protected void incrementChannelCount(Channel channel) { - channels.inc(); - } - - @Override - protected void decrementChannelCount(Channel channel) { - channels.dec(); - } - - @Override - protected void markPublishedMessage() { - publishedMessages.inc(); - } - - @Override - protected void markMessagePublishFailed() { - failedToPublishMessages.inc(); - } - - @Override - protected void markConsumedMessage() { - consumedMessages.inc(); - } - - @Override - protected void markAcknowledgedMessage() { - acknowledgedMessages.inc(); - } - - @Override - protected void markRejectedMessage() { - rejectedMessages.inc(); - } - - @Override - protected void markMessagePublishAcknowledged() { - ackedPublishedMessages.inc(); - } - - @Override - protected void markMessagePublishNotAcknowledged() { - nackedPublishedMessages.inc(); - } - - @Override - protected void markPublishedMessageUnrouted() { - unroutedPublishedMessages.inc(); - } + registry.register(rejectedMessages); + + } + + @Override + protected void incrementConnectionCount(Connection connection) { + connections.inc(); + } + + @Override + protected void decrementConnectionCount(Connection connection) { + connections.dec(); + } + + @Override + protected void incrementChannelCount(Channel channel) { + channels.inc(); + } + + @Override + protected void decrementChannelCount(Channel channel) { + channels.dec(); + } + + @Override + protected void markPublishedMessage() { + publishedMessages.inc(); + } + + @Override + protected void markMessagePublishFailed() { + failedToPublishMessages.inc(); + } + + @Override + protected void markConsumedMessage() { + consumedMessages.inc(); + } + + @Override + protected void markAcknowledgedMessage() { + acknowledgedMessages.inc(); + } + + @Override + protected void markRejectedMessage() { + rejectedMessages.inc(); + } + + @Override + protected void markMessagePublishAcknowledged() { + ackedPublishedMessages.inc(); + } + + @Override + protected void markMessagePublishNotAcknowledged() { + nackedPublishedMessages.inc(); + } + + @Override + protected void markPublishedMessageUnrouted() { + unroutedPublishedMessages.inc(); + } }