Function publish

config/rabbit.js:11–14

(eventType, message)

    const channel = await connection.createChannel();

    const publish = async (eventType, message) => {
        await channel.assertExchange(eventType, 'fanout');
        channel.publish(eventType, '', Buffer.from(JSON.stringify(message)));
    };

    return {
        channel,