Skip to content

Commit

Permalink
Merge pull request #94 from rabbitmq/dependabot/maven/micrometer.vers…
Browse files Browse the repository at this point in the history
…ion-1.13.0

Bump micrometer.version from 1.12.6 to 1.13.0

References #32
  • Loading branch information
acogoluegnes committed May 15, 2024
2 parents 670b2c9 + e5039f7 commit b4494e1
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@
<logback.version>1.5.6</logback.version>
<netty.version>4.1.109.Final</netty.version>
<metrics.version>4.2.25</metrics.version>
<micrometer.version>1.12.6</micrometer.version>
<micrometer.version>1.13.0</micrometer.version>
<picocli.version>4.7.6</picocli.version>
<guava.version>33.2.0-jre</guava.version>
<jgroups.version>5.3.6.Final</jgroups.version>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,8 +14,8 @@
// info@rabbitmq.com.
package com.rabbitmq.stream.perf;

import io.micrometer.prometheus.PrometheusConfig;
import io.micrometer.prometheus.PrometheusMeterRegistry;
import io.micrometer.prometheusmetrics.PrometheusConfig;
import io.micrometer.prometheusmetrics.PrometheusMeterRegistry;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import picocli.CommandLine.Option;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -393,7 +393,7 @@ void monitoringShouldReturnValidEndpoint() throws Exception {
HttpResponse response = httpRequest("http://localhost:" + monitoringPort + "/metrics");
return response.responseCode == 200
&& response.body.contains("# HELP rabbitmq_stream_published_total")
&& response.body.contains("rabbitmq_stream_chunk_size{quantile=\"0.5\",}")
&& response.body.contains("rabbitmq_stream_chunk_size{quantile=\"0.5\"}")
&& !response.body.contains("chunk_total");
});
run.cancel(true);
Expand All @@ -419,7 +419,7 @@ void metricsTagsShouldShowUpInHttpEndpoint() throws Exception {
() -> {
HttpResponse response = httpRequest("http://localhost:" + monitoringPort + "/metrics");
return response.responseCode == 200
&& response.body.contains("{datacenter=\"eu\",env=\"performance\",}");
&& response.body.contains("{datacenter=\"eu\",env=\"performance\"}");
});
run.cancel(true);
waitRunEnds();
Expand Down

0 comments on commit b4494e1

Please sign in to comment.