rbt

Documentation

Index

• type RabbitPublisher
  • func NewRabbitPublisher[T any](log log.LogRusEntry, rabbitURL string, exchangeName string, channelType string, ...) (RabbitPublisher[T], error)

Types

type RabbitPublisher

type RabbitPublisher[T any] interface {
	PublishForResult(data T, exchange string, routingKey string) error
	PublishTo(exchange string, routingKey string, data T) error
	Publish(data T) error
}

func NewRabbitPublisher

func NewRabbitPublisher[T any](
	log log.LogRusEntry,
	rabbitURL string,
	exchangeName string,
	channelType string,
	routingKey string,
) (RabbitPublisher[T], error)