Ignite outbound queue size

July 5, 2022

What's inside this article ⌄

Ignite outbound message queue size
Apache Ignite queue configuration
Ignite outbound queue settings
Configure Ignite message queue

If you want to limit outbound message queue size, you need to create an instance of TcpCommunicationSpi, and pass it to IgniteConfiguration:

public IgniteConfiguration clientIgniteConfiguration() {
    IgniteConfiguration igniteConfiguration = new IgniteConfiguration();
    TcpCommunicationSpi tcpCommunicationSpi = new TcpCommunicationSpi();
    tcpCommunicationSpi.setMessageQueueLimit(1024);
    igniteConfiguration.setCommunicationSpi(tcpCommunicationSpi);
    ...
    return igniteConfiguration;
}