mb

Documentation

Overview

a package for working with rabbit mq

Index

• func ProduceTextMsg(mb *MessageBroker, msg string) error
• func RunConsumer(mb *MessageBroker, handler func(data []byte)) error
• type MessageBroker
  • func InitMessageBroker(addr, user, pass, q_name string) (*MessageBroker, error)
  • func (message_broker *MessageBroker) Close()

Functions

func ProduceTextMsg

func ProduceTextMsg(mb *MessageBroker, msg string) error

ProduceTextMsg sends a text message to the queue

func RunConsumer

func RunConsumer(mb *MessageBroker, handler func(data []byte)) error

runs a consumer that listens for messages on the queue

Types

type MessageBroker

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

MessageBroker struct

func InitMessageBroker

func InitMessageBroker(addr, user, pass, q_name string) (*MessageBroker, error)

InitMessageBroker initializes a new message broker connection

func (*MessageBroker) Close

func (message_broker *MessageBroker) Close()

close message broker connection