clebertsuconic commented on code in PR #4552:
URL: https://github.com/apache/activemq-artemis/pull/4552#discussion_r1262311667
##########
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's blocked here is reading from paging. If you close a consumers those
messages will be delivered. But it won't read any more messages until these
are a mesma.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
