[ 
https://issues.apache.org/jira/browse/ARTEMIS-4362?focusedWorklogId=870777&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-870777
 ]

ASF GitHub Bot logged work on ARTEMIS-4362:
-------------------------------------------

                Author: ASF GitHub Bot
            Created on: 13/Jul/23 10:57
            Start Date: 13/Jul/23 10:57
    Worklog Time Spent: 10m 
      Work Description: clebertsuconic commented on code in PR #4552:
URL: https://github.com/apache/activemq-artemis/pull/4552#discussion_r1262391940


##########
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java:
##########
@@ -1584,4 +1584,7 @@ void slowConsumerDetected(String sessionID,
 
    @LogMessage(id = 224126, value = "Failure during protocol handshake on 
connection to {} from {}", level = LogMessage.Level.ERROR)
    void failureDuringProtocolHandshake(SocketAddress localAddress, 
SocketAddress remoteAddress, Throwable e);
+
+   @LogMessage(id = 224127, value = "Queue {}/Address {} is currently 
delivering {} messages that are holding {} bytes, with max reading sizes 
configured as addressSettings.maxPageReadMessages={} and 
addressSettings.maxPageReadBytes={}. System will not read more data from paging 
until acks are made. You can increase the address settings page-max-read 
attributes or make sure your consumers use lower batch sizes.", level = 
LogMessage.Level.WARN)

Review Comment:
   What about this one:
   
   "Message dispatch from paging is blocked. Address {}/Queue{} will not read 
any more messages from paging until pending messages are acknowledged. There 
are currently {} messages pending ({} bytes) with max reads at 
maxPageReadMessages({}) and maxPageReadBytes({}). Either increase reading 
attributes at the address-settings or change your consumers to acknowledge more 
often."
   





Issue Time Tracking
-------------------

    Worklog Id:     (was: 870777)
    Time Spent: 1h 40m  (was: 1.5h)

> Produce a logger when consumers are holding too many messages not allowing 
> deposing
> -----------------------------------------------------------------------------------
>
>                 Key: ARTEMIS-4362
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-4362
>             Project: ActiveMQ Artemis
>          Issue Type: Improvement
>            Reporter: Clebert Suconic
>            Priority: Major
>          Time Spent: 1h 40m
>  Remaining Estimate: 0h
>
> We should add a log.warn whenever the system can't read more messages because 
> consumers are holding too many messages in pending state.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to