Versions in this module Expand all Collapse all v1 v1.0.1 Jan 26, 2026 v1.0.0 Jan 23, 2026 Changes in this version + func WithRabbitMqMaxRetries(retries uint) func(*RabbitMqMessenger) + func WithRabbitMqRetryInterval(interval time.Duration) func(*RabbitMqMessenger) + func WithRabbitMqSerializer(serializer serialization.ISerializer) func(*RabbitMqMessenger) + func WithRabbitMqStreamBufferSize(size uint) func(*RabbitMqMessenger) + type IMessenger interface + Publish func(topic K, msg any) error + Subscribe func(topic K) async.Sequence[M] + Unsubscribe func(subsciption async.Sequence[M]) + func NewRabbitMqMessenger(ctx context.Context, host string, port uint16, user string, password string, ...) IMessenger[RabbitMqExchange, amqp.Delivery] + type RabbitMqExchange struct + Exchange string + RoutingKey string + Type string + type RabbitMqMessenger struct + func (r *RabbitMqMessenger) Publish(topic RabbitMqExchange, msg any) error + func (r *RabbitMqMessenger) Subscribe(topic RabbitMqExchange) async.Sequence[amqp.Delivery] + func (r *RabbitMqMessenger) Unsubscribe(subsciption async.Sequence[amqp.Delivery])
Go to main page