Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[AMQ-7443] Add connection remote addr in the prefetch warn log message 

(cherry picked from commit 7339e0516c)
This commit is contained in:
jbonofre 2021-01-13 06:23:28 +01:00
parent 34bc37d68d
commit 71be503447
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
activemq-broker/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
View File

@ -116,7 +116,11 @@ public class TopicSubscription extends AbstractSubscription {
if (info.getPrefetchSize() > 1 && matched.size() > info.getPrefetchSize()) { if (info.getPrefetchSize() > 1 && matched.size() > info.getPrefetchSize()) {
// Slow consumers should log and set their state as such. // Slow consumers should log and set their state as such.
if (!isSlowConsumer()) { if (!isSlowConsumer()) {
LOG.warn("{}: has twice its prefetch limit pending, without an ack; it appears to be slow", toString()); String remoteAddr = null;
if (context != null && context.getConnection() != null) {
remoteAddr = context.getConnection().getRemoteAddress();
}
LOG.warn("{}: has twice its prefetch limit pending, without an ack; it appears to be slow{}", toString(), (remoteAddr != null) ? ": " + remoteAddr : "");
setSlowConsumer(true); setSlowConsumer(true);
for (Destination dest: destinations) { for (Destination dest: destinations) {
dest.slowConsumer(getContext(), this); dest.slowConsumer(getContext(), this);
@ -133,7 +137,7 @@ public class TopicSubscription extends AbstractSubscription {
return; return;
} }
if (!warnedAboutWait) { if (!warnedAboutWait) {
LOG.info("{}: Pending message cursor [{}] is full, temp usag ({}%) or memory usage ({}%) limit reached, blocking message add() pending the release of resources.", LOG.info("{}: Pending message cursor [{}] is full, temp usage ({}%) or memory usage ({}%) limit reached, blocking message add() pending the release of resources.",
new Object[]{ new Object[]{
toString(), toString(),
matched, matched,