Documentation ¶ Index ¶ func CreateChannel(conn *amqp.Connection) (*amqp.Channel, error) func DeclareQueue(ch *amqp.Channel, cfg *config.Config) (*amqp.Queue, error) func NewAMQP(c *config.Config) (*amqp.Connection, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func CreateChannel ¶ func CreateChannel(conn *amqp.Connection) (*amqp.Channel, error) func DeclareQueue ¶ func DeclareQueue(ch *amqp.Channel, cfg *config.Config) (*amqp.Queue, error) func NewAMQP ¶ func NewAMQP(c *config.Config) (*amqp.Connection, error) Types ¶ This section is empty. Source Files ¶ View all Source files conn.go Click to show internal directories. Click to hide internal directories.