rbt

Documentation

Index

• func ConsumeRabbitEvent[T any](fluentUrl string, rabbitUrl string, serverName string, exchangeName string, ...) error
• func RbtLogger(fluentUrl string, serverName string, correlationId string) log.LogRusEntry
• type InputMessage
• type RabbitPublisher
  • func NewRabbitPublisher[T any](log log.LogRusEntry, rabbitURL string, exchangeName string, channelType string, ...) (RabbitPublisher[T], error)

Functions

func ConsumeRabbitEvent

func ConsumeRabbitEvent[T any](
	fluentUrl string,
	rabbitUrl string,
	serverName string,
	exchangeName string,
	channelType string,
	queueName string,
	routingKey string,
	processIncomingMessage func(log.LogRusEntry, *InputMessage[T]),
) error

func RbtLogger

func RbtLogger(fluentUrl string, serverName string, correlationId string) log.LogRusEntry

Types

type InputMessage

type InputMessage[T any] struct {
	CorrelationId string `json:"correlation_id" example:"123123" `
	RoutingKey    string `json:"routing_key" example:"Remote RoutingKey to Reply"`
	Exchange      string `json:"exchange" example:"Remote Exchange to Reply"`
	Message       T
}

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
	Logger() log.LogRusEntry
}

func NewRabbitPublisher

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