nizhikov commented on code in PR #12339:
URL: https://github.com/apache/ignite/pull/12339#discussion_r2624158293
##########
modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/TcpCommunicationConfigInitializer.java:
##########
@@ -690,6 +690,33 @@ public int getMessageQueueLimit() {
return cfg.messageQueueLimit();
}
+ /**
+ * Sets message queue size to print warning.
+ * <p>
+ * When set to positive number warning will be produced when outgoing
message queue size exeeds provided size.
+ * {@code 0} disables the warning.
+ * <p>
+ * If not provided, default is 0 (do not print warning).
+ *
+ * @param msgQueueWarnSize Outgoing messages queue size to print warning.
+ * @return {@code this} for chaining.
+ */
+ @IgniteSpiConfiguration(optional = true)
+ public TcpCommunicationSpi setMessageQueueWarningSize(int
msgQueueWarnSize) {
Review Comment:
Do we want to make this new API stable from the first merge?
Do we need IgniteExperimental annotation here?
--
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]
