rabbitmq

Documentation

Index

• func NewInstance(rabbitHost string, rabbitPort string, messagebrokeruser string, ...) (*amqp.Connection, error)
• func NewQueueConsumer(connection *amqp.Connection, queueName string, exchange string, ...) (<-chan amqp.Delivery, error)
• func NewQueuePublisher(connection *amqp.Connection, exchange string) (*amqp.Channel, error)
• func PublishMessage(channel *amqp.Channel, exchange string, routingKey string, header amqp.Table, ...) error
• type RMQChannel
• type RMQConnection

Functions

func NewInstance

func NewInstance(rabbitHost string, rabbitPort string, messagebrokeruser string, messagebrokerpassword string) (*amqp.Connection, error)

func NewQueueConsumer

func NewQueueConsumer(connection *amqp.Connection, queueName string, exchange string, routingKey string) (<-chan amqp.Delivery, error)

func NewQueuePublisher

func NewQueuePublisher(connection *amqp.Connection, exchange string) (*amqp.Channel, error)

func PublishMessage

func PublishMessage(channel *amqp.Channel, exchange string, routingKey string, header amqp.Table, message []byte) error

Types

type RMQChannel

type RMQChannel struct {
	*amqp.Channel
}

type RMQConnection

type RMQConnection struct {
	*amqp.Connection
}