amqp

package

v0.74.0 Latest Latest Go to latest Published: Jan 28, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Package amqp provides a client with included tracing capabilities.

This section is empty.

This section is empty.

This section is empty.

type OptionFunc func(*Publisher) error

OptionFunc definition for configuring the publisher in a functional way.

func WithConfig(cfg amqp.Config) OptionFunc

WithConfig option for providing dial configuration.

type Publisher struct {
	// contains filtered or unexported fields
}

Publisher defines a RabbitMQ publisher with tracing instrumentation.

func New(url string, oo ...OptionFunc) (*Publisher, error)

New constructor.

func (tc *Publisher) Close() error

Close the channel and connection.

func (tc *Publisher) Publish(ctx context.Context, exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

Publish a message to an exchange.