MessageSystem

Documentation

Index

• func ConsumeOne[T interface{}](RABBITMQ, QUEUE string, logger Logger.LoggerService) (T, error)
• func Consumer[T interface{}](messageBus chan ConsumerMsgResp[T], RABBITMQ, QUEUE, EXCHANGENAME string, ...)
• func CreateAQueue(channel *amqp.Channel, QUEUE string, Exclusive bool, ...) error
• func CreateAndBind(RABBITMQ, QUEUE, EXCHANGE string, logger Logger.LoggerService) error
• func CreateAndBindQueue(channel *amqp.Channel, QUEUE, EXCHANGENAME string, logger Logger.LoggerService) error
• func ProducerBroadCast(Message interface{}, RABBITMQ, EXCHANGENAME string, ...) error
• func Publish(Message interface{}, RABBITMQ, QUEUE string, Exclusive bool, ...) error
• type ConsumerMsgResp

Functions

func ConsumeOne

func ConsumeOne[T interface{}](RABBITMQ, QUEUE string, logger Logger.LoggerService) (T, error)

• CunsumeOne - Create a consumer for T type messages @generic T - interface{}{} @Param RABBITMQ string @Param QUEUE string @Param logger Logger.LoggerService @Returns T ,error

func Consumer

func Consumer[T interface{}](messageBus chan ConsumerMsgResp[T], RABBITMQ, QUEUE, EXCHANGENAME string, logger Logger.LoggerService)

• Cunsumer - Create a consumer for T type messages @generic T - interface{}{} @Param messageBus chan ConsumerMsgResp[T] @Param RABBITMQ string @Param QUEUE string @Param EXCHANGENAME string @Param logger Logger.LoggerService

func CreateAQueue

func CreateAQueue(channel *amqp.Channel, QUEUE string, Exclusive bool, logger Logger.LoggerService) error

* CreateAQueue - create a Queue @Param channel * amqp.Channel @Param QUEUE string @Param Exclusive bool @Param logger Logger.LoggerService

func CreateAndBind

func CreateAndBind(RABBITMQ, QUEUE, EXCHANGE string, logger Logger.LoggerService) error

func CreateAndBindQueue

func CreateAndBindQueue(channel *amqp.Channel, QUEUE, EXCHANGENAME string, logger Logger.LoggerService) error

* CreateAndBindQueue - create and bind queue in to an exachange Topic @Param channel * amqp.Channel @Param QUEUE string @Param EXCHANGENAME string @Param logger Logger.LoggerService

func ProducerBroadCast

func ProducerBroadCast(Message interface{}, RABBITMQ, EXCHANGENAME string, logger Logger.LoggerService) error

ProducerBroadcast - Produce A Message and Brodacast The Message @Param Message - interface {} @Param RABBITMQ string @Param EXCHANGENAME string

func Publish

func Publish(Message interface{}, RABBITMQ, QUEUE string, Exclusive bool, logger Logger.LoggerService) error

Publish - publish A Message to Queue @Param Message - interface {} @Param RABBITMQ string @Param EXCHANGENAME string

Types

type ConsumerMsgResp

type ConsumerMsgResp[T interface{}] struct {
	Payload T
	Err     error
}