Documentation
¶
Index ¶
- func Connect() (*amqp.Connection, error)
- func ConsumeMessages(queue string, channel *amqp.Channel) (<-chan amqp.Delivery, error)
- func CreateChannel(connection *amqp.Connection) (*amqp.Channel, error)
- func CreateExchange(channel *amqp.Channel) error
- func CreateMessage(body string) amqp.Publishing
- func CreateQueueAndBind(channel *amqp.Channel, queue string) error
- func EstablishPublishQueue(channel *amqp.Channel) error
- func PublishMessage(message amqp.Publishing, channel *amqp.Channel) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
func Connect() (*amqp.Connection, error)
Connect establishes a connection to the RabbitMQ instance
func ConsumeMessages ¶
ConsumeMessages subscribes and waits for messages in the queue
func CreateChannel ¶
func CreateChannel(connection *amqp.Connection) (*amqp.Channel, error)
CreateChannel create a channel from the given connection
func CreateExchange ¶
CreateExchange creates an events exchange
func CreateMessage ¶
func CreateMessage(body string) amqp.Publishing
CreateMessage takes in our message body and creates a message to used sent in our queue
func CreateQueueAndBind ¶
CreateQueueAndBind declares a queue and binds it to our channel
func EstablishPublishQueue ¶
EstablishPublishQueue create exchange & links queue
func PublishMessage ¶
func PublishMessage(message amqp.Publishing, channel *amqp.Channel) error
PublishMessage sends our RabbitMQ messages to the queue
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.