Skip to content

Commit dd28c82

Browse files
committed
Add debug log message in performance tool
To track activity.
1 parent 6137f5e commit dd28c82

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/main/java/com/rabbitmq/stream/perf/DefaultPerformanceMetrics.java

+7
Original file line numberDiff line numberDiff line change
@@ -326,6 +326,13 @@ boolean checkActivity() {
326326
boolean activity =
327327
this.lastPublishedCount != currentPublishedCount
328328
|| this.lastConsumedCount != currentConsumedCount;
329+
LOGGER.debug(
330+
"Activity check: published {} vs {}, consumed {} vs {}, activity {}",
331+
this.lastPublishedCount,
332+
currentPublishedCount,
333+
this.lastConsumedCount,
334+
currentConsumedCount,
335+
activity);
329336
if (activity) {
330337
this.lastPublishedCount = currentPublishedCount;
331338
this.lastConsumedCount = currentConsumedCount;

0 commit comments

Comments
 (0)