amqp

Documentation

Index

• type Message
  • func NewJSONMessage(d interface{}) (*Message, error)
  • func NewMessage(ct string, body []byte) *Message
• type Publisher
• type TracedPublisher
  • func NewPublisher(url, exc string) (*TracedPublisher, error)
  • func (tc *TracedPublisher) Close(ctx context.Context) error
  • func (tc *TracedPublisher) Publish(ctx context.Context, msg *Message) error

Types

type Message

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

Message abstraction for publishing.

func NewJSONMessage

func NewJSONMessage(d interface{}) (*Message, error)

NewJSONMessage creates a new message with a JSON encoded body.

func NewMessage

func NewMessage(ct string, body []byte) *Message

NewMessage creates a new message.

type Publisher

type Publisher interface {
	Publish(ctx context.Context, msg *Message) error
	Close(ctx context.Context) error
}

Publisher interface of a RabbitMQ publisher.

type TracedPublisher

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

TracedPublisher defines a RabbitMQ publisher with tracing instrumentation.

func NewPublisher

func NewPublisher(url, exc string) (*TracedPublisher, error)

NewPublisher creates a new publisher with the following defaults - exchange type: fanout - notifications are not handled at this point TBD.

func (*TracedPublisher) Close

func (tc *TracedPublisher) Close(ctx context.Context) error

Close the connection and channel of the publisher.

func (*TracedPublisher) Publish

func (tc *TracedPublisher) Publish(ctx context.Context, msg *Message) error

Publish a message to a exchange.