amqp

Documentation

Overview

Package amqp implements an AMQP binding.

Index

• func EncodeAMQPMessage(ctx context.Context, m binding.Message, amqpMessage *amqp.Message, ...) error
• func NewSender(amqpClient *amqp.Sender, options ...SenderOptionFunc) binding.Sender
• type Message
  • func NewMessage(message *amqp.Message) *Message
  • func (m *Message) Binary(ctx context.Context, encoder binding.BinaryEncoder) error
  • func (m *Message) Encoding() binding.Encoding
  • func (m *Message) Finish(err error) error
  • func (m *Message) Structured(ctx context.Context, encoder binding.StructuredEncoder) error
• type Receiver
  • func (r *Receiver) Close(ctx context.Context) error
  • func (r *Receiver) Receive(ctx context.Context) (binding.Message, error)
• type Sender
  • func (s *Sender) Close(ctx context.Context) error
  • func (s *Sender) Send(ctx context.Context, in binding.Message) error
• type SenderOptionFunc
  • func WithTranscoder(factory binding.TransformerFactory) SenderOptionFunc

Functions

func EncodeAMQPMessage

func EncodeAMQPMessage(ctx context.Context, m binding.Message, amqpMessage *amqp.Message, transformerFactories binding.TransformerFactories) error

Fill the provided amqpMessage with the message m. Using context you can tweak the encoding processing (more details on binding.Translate documentation).

func NewSender

func NewSender(amqpClient *amqp.Sender, options ...SenderOptionFunc) binding.Sender

Types

type Message

type Message struct {
	AMQP *amqp.Message
	// contains filtered or unexported fields
}

Message implements binding.Message by wrapping an *amqp.Message.

func NewMessage

func NewMessage(message *amqp.Message) *Message

func (*Message) Binary

func (m *Message) Binary(ctx context.Context, encoder binding.BinaryEncoder) error

func (*Message) Encoding

func (m *Message) Encoding() binding.Encoding

func (*Message) Finish

func (m *Message) Finish(err error) error

func (*Message) Structured

func (m *Message) Structured(ctx context.Context, encoder binding.StructuredEncoder) error

type Receiver

type Receiver struct{ AMQP *amqp.Receiver }

Receiver wraps an amqp.Receiver as a binding.Receiver

func (*Receiver) Close

func (r *Receiver) Close(ctx context.Context) error

func (*Receiver) Receive

func (r *Receiver) Receive(ctx context.Context) (binding.Message, error)

type Sender

type Sender struct {
	AMQP *amqp.Sender
	// contains filtered or unexported fields
}

Sender wraps an amqp.Sender as a binding.Sender

func (*Sender) Close

func (s *Sender) Close(ctx context.Context) error

func (*Sender) Send

func (s *Sender) Send(ctx context.Context, in binding.Message) error

type SenderOptionFunc

type SenderOptionFunc func(sender *Sender)

func WithTranscoder

func WithTranscoder(factory binding.TransformerFactory) SenderOptionFunc