queue

Documentation

Index

• Constants
• func Listen(qName string, messageProcessor MessageProcessor)
• func Send(qName string, message string) error
• type MessageProcessor

Constants

const (
	SIRIUS_RABBITMQ = "amqp://guest:guest@sirius-rabbitmq:5672/"
)

Functions

func Listen

func Listen(qName string, messageProcessor MessageProcessor)

Listen listens to a RabbitMQ queue specified by qName and processes messages using the provided messageProcessor function.

func Send

func Send(qName string, message string) error

Send sends a message to a RabbitMQ queue specified by qName.

Types

type MessageProcessor

type MessageProcessor func(msg string)

MessageProcessor is a type for functions that can process messages.