Only one retained message received about esp32-mqtt HOT 2 OPEN

void deliver_publish(mqtt_client *client, uint8_t *message, int length)
{
	mqtt_event_data_t event_data;
	int len_read = 0, total_mqtt_len = 0, mqtt_len = 0, mqtt_offset = 0;
	do
	{
		do{
			event_data.topic_length = length;
			event_data.topic = mqtt_get_publish_topic(message+mqtt_offset, &event_data.topic_length);
			event_data.data_length = length;
			event_data.data = mqtt_get_publish_data(message+mqtt_offset, &event_data.data_length);

			//mqtt_info("message_length: %d bytes message_length_read: %d bytes, data_length: %d bytes ", client->mqtt_state.message_length, client->mqtt_state.message_length_read, event_data.data_length);
			total_mqtt_len = client->mqtt_state.message_length_read;
			mqtt_len = event_data.data_length + event_data.topic_length + 4;

			event_data.data_total_length = total_mqtt_len;
			event_data.data_offset = mqtt_offset;
			if(client->settings->data_cb) {
				client->settings->data_cb(client, &event_data);
			}
			mqtt_offset += mqtt_len;
		}while (mqtt_offset < total_mqtt_len);

        if (client->mqtt_state.message_length_read >= client->mqtt_state.message_length)
            break;

        len_read = client->settings->read_cb(client, client->mqtt_state.in_buffer, CONFIG_MQTT_BUFFER_SIZE_BYTE, 0);
        if(len_read < 0) {
            mqtt_info("Read error: %d", errno);
            break;
        }
        client->mqtt_state.message_length_read += len_read;
    } while (1);
}