rabbitmq

Documentation

Index

• Variables
• func BuildMqConnAddr() string
• func ConsumeMessage(ctx context.Context, queueName string) (msg <-chan amqp.Delivery, err error)
• func ExtractAMQPHeaders(ctx context.Context, headers map[string]interface{}) context.Context
• func InjectAMQPHeaders(ctx context.Context) map[string]interface{}
• func SendMessage2MQ(body []byte, queueName string) (err error)
• type AmqpHeadersCarrier
  • func (a AmqpHeadersCarrier) Get(key string) string
  • func (a AmqpHeadersCarrier) Keys() []string
  • func (a AmqpHeadersCarrier) Set(key string, value string)

Variables

var RabbitMQ *amqp.Connection

Functions

func BuildMqConnAddr

func BuildMqConnAddr() string

func ConsumeMessage

func ConsumeMessage(ctx context.Context, queueName string) (msg <-chan amqp.Delivery, err error)

func ExtractAMQPHeaders

func ExtractAMQPHeaders(ctx context.Context, headers map[string]interface{}) context.Context

func InjectAMQPHeaders

func InjectAMQPHeaders(ctx context.Context) map[string]interface{}

func SendMessage2MQ

func SendMessage2MQ(body []byte, queueName string) (err error)

Types

type AmqpHeadersCarrier

type AmqpHeadersCarrier map[string]interface{}

func (AmqpHeadersCarrier) Get

func (a AmqpHeadersCarrier) Get(key string) string

func (AmqpHeadersCarrier) Keys

func (a AmqpHeadersCarrier) Keys() []string

func (AmqpHeadersCarrier) Set

func (a AmqpHeadersCarrier) Set(key string, value string)