RabbitMQ service. The publisher doesn't need to declare exchange, queue and do the binding

Bad.py

from models.item import Item
from json import dumps
from pika import (
    BlockingConnection,
    ConnectionParameters,
    BasicProperties
)


async def register_item_service(item:dict)->Item:
    _itemr = dict(item)
    message = dumps(_itemr)
    
    connection =  BlockingConnection( ConnectionParameters(host='localhost'))
    channel = connection.channel()
    exchange = channel.exchange_declare(exchange="inventory-exchange", exchange_type='fanout',durable=True)
    queue = channel.queue_declare(queue='register-item-queue', durable=True)
    qu = queue.method.queue
    channel.queue_bind(exchange="inventory-exchange", queue=qu,routing_key="register-key")
    channel.basic_publish(
        exchange="inventory-exchange",
        routing_key="register_key",
        body= message,
        properties= BasicProperties(
            content_type="application/json",
            delivery_mode= 2
        )
    )
    connection.close()
    
    if _itemr:
        return Item(**_itemr)
     

good.py

from models.item import Item
from json import dumps
from core.settings import setting
from pika import (
    BlockingConnection,
    ConnectionParameters,
    BasicProperties
)

async def register_item_service(item:dict)->Item:
    _itemr = dict(item)
    message = dumps(_itemr)
    
    connection =  BlockingConnection( 
        ConnectionParameters(host=setting.rabbitmq_host)
    )
    channel = connection.channel()
    channel.basic_publish(
        exchange=setting.exchange,
        routing_key=setting.routing_key,
        body= message,
        properties= BasicProperties(
            content_type="application/json",
            delivery_mode= 2
        )
    )
    connection.close()
    
    if _itemr:
        return Item(**_itemr)