package rabbitmq

import (
	"github.com/UpmeshLTD/urus-aio/infrastructure/broker"
	"github.com/UpmeshLTD/urus-aio/shipment/config"
	"github.com/UpmeshLTD/urus-aio/shipment/log"
)

func NewRabbitmqMessageBroker(config config.Config, logger log.Logger) broker.MessageBroker {
	if config.GetMessageBrokerConfig().Uri == "" {
		return &broker.MockMessageBroker{}
	}

	return &broker.RabbitmqMessageBroker{
		Logger: logger,
		Config: config.GetMessageBrokerConfig(),
	}
}