The unblock message is lost.

[dormanze]

Hello, everyone.
rabbitmq version:3.11.9
amqp-client:5.14.2
My client implements BlockedListener to listen to whether a connection is blocked.

    private void addBlockedListener(Connection connection) {
        connection.addBlockedListener(new BlockedListener() {
            @Override
            public void handleBlocked(String reason) {
                RUNTIME_LOG.error("Rabbitmq blocked. {}", reason);
                rabbitmqBlocked = true;
            }

            @Override
            public void handleUnblocked() {
                RUNTIME_LOG.info("Rabbitmq unBlocked.");
                rabbitmqBlocked = false;
            }
        });
    }

The memory of the server frequently exceeds the high watermark due to a large number of queues.

2023-10-29 02:41:35.233176+08:00 [warning] <0.27214.3> memory resource limit alarm set on node 'rabbit@rabbitmqservice-1'.
2023-10-29 02:41:35.233176+08:00 [warning] <0.27214.3>
2023-10-29 02:41:35.233176+08:00 [warning] <0.27214.3> **********************************************************
2023-10-29 02:41:35.233176+08:00 [warning] <0.27214.3> *** Publishers will be blocked until this alarm clears ***
2023-10-29 02:41:35.233176+08:00 [warning] <0.27214.3> **********************************************************
2023-10-29 02:41:35.233176+08:00 [warning] <0.27214.3>
2023-10-29 02:41:37.233677+08:00 [warning] <0.27214.3> memory resource limit alarm cleared on node 'rabbit@rabbitmqservice-1'
2023-10-29 02:41:37.233811+08:00 [warning] <0.27214.3> memory resource limit alarm cleared across the cluster
2023-10-29 02:41:38.235504+08:00 [warning] <0.27214.3> memory resource limit alarm set on node 'rabbit@rabbitmqservice-1'.
2023-10-29 02:41:38.235504+08:00 [warning] <0.27214.3>
2023-10-29 02:41:38.235504+08:00 [warning] <0.27214.3> **********************************************************
2023-10-29 02:41:38.235504+08:00 [warning] <0.27214.3> *** Publishers will be blocked until this alarm clears ***
2023-10-29 02:41:38.235504+08:00 [warning] <0.27214.3> **********************************************************
2023-10-29 02:41:38.235504+08:00 [warning] <0.27214.3>
2023-10-29 02:41:39.242438+08:00 [warning] <0.27214.3> memory resource limit alarm cleared on node 'rabbit@rabbitmqservice-1'
2023-10-29 02:41:39.242550+08:00 [warning] <0.27214.3> memory resource limit alarm cleared across the cluster

At the same time, my client will receive the block connection and unblock notification.
However, from a certain time point, the listener of the client can receive only the block notification, and the unblock notification is not received.
Except the following logs, there are no other abnormal logs on the server. I do not know whether this is a known problem.

2023-10-28 17:38:04.645518+08:00 [error] <0.2705.6908> Error on AMQP connection <0.2705.6908> (172.18.0.81:59988 -> 172.18.0.154:5673, vhost: '/vhost_gam', user: 'rabbitmq_gam', state: blocked), channel 553:
2023-10-28 17:38:04.645518+08:00 [error] <0.2705.6908>  operation channel.open caused a connection exception channel_error: "second 'channel.open' seen"

[lukebakken]

from a certain time point, the listener of the client can receive only the block notification, and the unblock notification is not received

Is the "certain time point" consistent, or reasonably consistent? In other words, do you stop getting "unblock" after a certain number of "block" notifications?

Can you get a packet trace showing the point at which your client gets its last "unblock" followed by several "blocks"? That would tell us if it is a RabbitMQ problem or a client library problem.

[dormanze]

I have two client instances. One client has not received an unblock message since 17:32 on October 28, and the other client has not received an unblock message since 02:44 on October 27. At the same time, the two instances continuously receive block messages. I prefer that the server is faulty and no unblock messages are pushed to the client after a certain time point. The client simply adds a listener, as shown in my code above, and does not limit the number of times unblocks can be received.

 private void addBlockedListener(Connection connection) {
        connection.addBlockedListener(new BlockedListener() {
            @Override
            public void handleBlocked(String reason) {
                RUNTIME_LOG.error("Rabbitmq blocked. {}", reason);
                rabbitmqBlocked = true;
            }

            @Override
            public void handleUnblocked() {
                RUNTIME_LOG.info("Rabbitmq unBlocked.");
                rabbitmqBlocked = false;
            }
        });
    }