Implementing a rabbitmq transport object

[Liad-n]

So I tried to create a rabbitmq transport element containing the connection, channel for sending, channel for consuming and  declaring the queues and exchange.
After losing connection it reconnects well, but after rabbitmq resets the queues and exchange get deleted and have to be recreated.
eventhough the connection gets replaced with the fixed one in the package, it still gives me an error of channel/connection are closed.
Also I didn't succeed checking if connection.IsClosed as it always returns false.

rabbitmq version: 3.8.9
environment: local k3s cluster

Thanks