amqpfx

func ConsumerModule[T consumer.Message](
	handler consumer.Handler[T],
	queueOptions consumer.QueueDeclare,
	connectionOptions connection.Config,
	options ...consumer.Option[T],
) fx.Option

func ConsumerModuleFunc[T consumer.Message](
	handler func(context.Context, T) error,
	queueOptions consumer.QueueDeclare,
	connectionOptions connection.Config,
	options ...consumer.Option[T],
) fx.Option

func ConsumerModuleRaw[T consumer.Message](
	handler consumer.RawHandler,
	queueOptions consumer.QueueDeclare,
	connectionOptions connection.Config,
	options ...consumer.Option[T],
) fx.Option

func ConsumerModuleRawFunc[T consumer.Message](
	handler func(context.Context, *amqp091.Delivery) error,
	queueOptions consumer.QueueDeclare,
	connectionOptions connection.Config,
	options ...consumer.Option[T],
) fx.Option

func GetPublisherName(connectionName, exchangeName string) string

func GetPublisherParamName(connectionName, exchangeName string) string

func PublisherModule[T any](
	connectionOptions connection.Config,
	exchangeName string,
	options ...publisher.Option[T],
) fx.Option