queue

Documentation

Index

• type Conn
  • func GetConn(rabbitURL string) (Conn, error)
  • func (conn Conn) Publish(exchange string, key string, msg amqp.Publishing) error

Types

type Conn

type Conn struct {
	Channel    *amqp.Channel
	Connection *amqp.Connection
}

Conn struct

func GetConn

func GetConn(rabbitURL string) (Conn, error)

func (Conn) Publish

func (conn Conn) Publish(exchange string, key string, msg amqp.Publishing) error