diff --git a/src/integration-tests/test_delete_domain.py b/src/integration-tests/test_delete_domain.py
new file mode 100644
index 000000000..ae8604171
--- /dev/null
+++ b/src/integration-tests/test_delete_domain.py
@@ -0,0 +1,218 @@
+# Copyright 2024 Bloomberg Finance L.P.
+# SPDX-License-Identifier: Apache-2.0
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+"""
+Testing deletion of domains.
+"""
+
+import blazingmq.dev.it.testconstants as tc
+from blazingmq.dev.it.fixtures import Cluster, cluster
+from blazingmq.dev.it.process.client import ITError
+from blazingmq.dev.it.process.admin import AdminClient
+
+
+def test_domain_deletion_fail_confirm(cluster: Cluster):
+    """
+    1. Connect producer and consumer to BMQ on `domain1/qqq`
+    2. Producer produces 5 messages, and the consumer consumes all 5
+    3. Delete config of `domain1` on the disk
+    4. Restart the broker, while producer and consumer are still alive
+    5. Consumer couldn't connect with the broker, thus fails to confirm messages
+    6. Producer can still put messages
+    """
+    proxies = cluster.proxy_cycle()
+
+    producer = next(proxies).create_client("producer")
+    producer.open(tc.URI_PRIORITY, flags=["write"], succeed=True)
+
+    consumer = next(proxies).create_client("consumer")
+    consumer.open(tc.URI_PRIORITY, flags=["read"], succeed=True)
+
+    producer.post(
+        tc.URI_PRIORITY, [f"msg{i}" for i in range(5)], succeed=True, wait_ack=True
+    )
+
+    assert consumer.wait_push_event()
+
+    for node in cluster.configurator.brokers.values():
+        del node.domains[tc.DOMAIN_PRIORITY]
+    cluster.deploy_domains()
+
+    cluster._logger.info("================== BEFORE SHUTDOWN ==================")
+
+    for node in cluster.nodes():
+        node.force_stop()
+
+    cluster._logger.info("================== BEFORE RESTART ==================")
+
+    cluster.start_nodes(wait_ready=True)
+
+    cluster._logger.info("================== AFTER ==================")
+
+    # try:
+    #     consumer.confirm(tc.URI_PRIORITY, "+1", succeed=True)
+    # except ITError as e:
+    #     print(e)
+
+    # producer.post(tc.URI_PRIORITY, ["msg5"], succeed=True)
+
+
+def test_domain_deletion_fail_open_queue(cluster: Cluster):
+    """
+    1. Connect producer and consumer to BMQ on `domain1/qqq`
+    2. Producer produces 5 messages, and the consumer consumes all 5
+    3. Delete config of `domain1` on the disk
+    4. Restart the broker, while producer and consumer are still alive
+    5. Both producer and consumer would throw ITError when they try to open
+       a queue on the deleted domain
+    """
+    proxies = cluster.proxy_cycle()
+
+    producer = next(proxies).create_client("producer")
+    producer.open(tc.URI_PRIORITY, flags=["write"], succeed=True)
+
+    consumer = next(proxies).create_client("consumer")
+    consumer.open(tc.URI_PRIORITY, flags=["read"], succeed=True)
+
+    producer.post(
+        tc.URI_PRIORITY, [f"msg{i}" for i in range(5)], succeed=True, wait_ack=True
+    )
+
+    assert consumer.wait_push_event()
+
+    for node in cluster.configurator.brokers.values():
+        del node.domains[tc.DOMAIN_PRIORITY]
+    cluster.deploy_domains()
+
+    for node in cluster.nodes():
+        node.force_stop()
+    cluster.start_nodes(wait_ready=True)
+
+    try:
+        producer.open(tc.URI_PRIORITY, flags=["write"], succeed=True)
+    except ITError as e:
+        print(e)
+
+    try:
+        consumer.open(tc.URI_PRIORITY, flags=["read"], succeed=True)
+    except ITError as e:
+        print(e)
+
+
+def test_domain_deletion_produce_more_after_delete_domain(cluster: Cluster):
+    """
+    1. Connect producer and consumer to BMQ on `domain1/qqq`
+    2. Producer produces 5 messages
+    3. Delete config of `domain1` on the disk
+    4. Producer produces 2 more messages
+    5. Restart the broker
+    6. Consumer couldn't connect with the broker, thus fails to confirm messages
+    """
+    proxies = cluster.proxy_cycle()
+
+    producer = next(proxies).create_client("producer")
+    producer.open(tc.URI_PRIORITY, flags=["write"], succeed=True)
+
+    consumer = next(proxies).create_client("consumer")
+    consumer.open(tc.URI_PRIORITY, flags=["read"], succeed=True)
+
+    producer.post(
+        tc.URI_PRIORITY, [f"msg{i}" for i in range(5)], succeed=True, wait_ack=True
+    )
+
+    for node in cluster.configurator.brokers.values():
+        del node.domains[tc.DOMAIN_PRIORITY]
+    cluster.deploy_domains()
+
+    producer.post(
+        tc.URI_PRIORITY,
+        [f"msg{i}" for i in range(5, 7)],
+        succeed=True,
+        wait_ack=True,
+    )
+
+    for node in cluster.nodes():
+        node.force_stop()
+    cluster.start_nodes(wait_ready=True)
+
+    try:
+        consumer.confirm(tc.URI_PRIORITY, "+1", succeed=True)
+    except ITError as e:
+        print(e)
+
+
+def test_domain_deletion_add_back(cluster: Cluster):
+    """
+    1. Connect producer only to BMQ on `domain1/qqq`
+    2. Producer produces 5 messages
+    3. Producer closes queue
+    4. Delete config of `domain1` on the disk
+    5. Restart broker
+    6. Add config of `domain1` back on the disk (with or without different config parameters)
+    7. Invoke `DOMAIN RECONFIGURE` command to reload the config on the broker
+    8. Producer opens the queue once again
+    9. Producer produces 2 more messages
+    10. Now, start a consumer to open the queue and try to confirm messages. Consumer sees 2 messages.
+    11. Check to see `domain1/qqq` appears only in one partition
+    """
+    proxies = cluster.proxy_cycle()
+
+    producer = next(proxies).create_client("producer")
+    producer.open(tc.URI_PRIORITY, flags=["write"], succeed=True)
+
+    producer.post(
+        tc.URI_PRIORITY, [f"msg{i}" for i in range(5)], succeed=True, wait_ack=True
+    )
+
+    producer.close(tc.URI_PRIORITY, succeed=True)
+
+    domain_config = cluster.config.domains[tc.DOMAIN_PRIORITY]
+
+    for node in cluster.configurator.brokers.values():
+        del node.domains[tc.DOMAIN_PRIORITY]
+    cluster.deploy_domains()
+
+    for node in cluster.nodes():
+        node.force_stop()
+    cluster.start_nodes(wait_ready=True)
+
+    domain_config.definition.parameters.max_consumers = 100
+
+    for node in cluster.configurator.brokers.values():
+        node.domains[tc.DOMAIN_PRIORITY] = domain_config
+    cluster.deploy_domains()
+
+    cluster.reconfigure_domain(tc.DOMAIN_PRIORITY, succeed=True)
+
+    producer.open(tc.URI_PRIORITY, flags=["write"], succeed=True)
+
+    producer.post(
+        tc.URI_PRIORITY, [f"msg{i}" for i in range(5, 7)], succeed=True, wait_ack=True
+    )
+
+    consumer = next(proxies).create_client("consumer")
+    consumer.open(tc.URI_PRIORITY, flags=["read"], block=True, succeed=True)
+
+    assert consumer.wait_push_event()
+    msgs = consumer.list(tc.URI_PRIORITY, block=True)
+    assert len(msgs) == 2
+
+    leader = cluster.last_known_leader
+    admin = AdminClient()
+    admin.connect(leader.config.host, int(leader.config.port))
+    res = admin.send_admin(f"CLUSTERS CLUSTER {cluster.name} STORAGE SUMMARY")
+    assert res.count("Number of assigned queue-storages: 1") == 1
+
+    admin.stop()