amqp

package
v0.0.0-...-a3f283a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2020 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AMQPConn

type AMQPConn struct {
	*amqp.Connection
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance() *AMQPConn

func (*AMQPConn) Close

func (conn *AMQPConn) Close() error

func (*AMQPConn) Connect

func (conn *AMQPConn) Connect(url string) error

func (*AMQPConn) CreateQueue

func (conn *AMQPConn) CreateQueue(queueName string) error

func (*AMQPConn) GetChannel

func (conn *AMQPConn) GetChannel() *amqp.Channel

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL