amqp

package

v0.0.4 Latest Latest Go to latest Published: Jul 25, 2022 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrClosed = errors.New("amqp connection pool is closed")
)

func NewConsumerConn(key message.Key, config contract.Config) (contract.Consumer, error)

NewConsumerConn new consumer connection

func NewProducerConn(key message.Key, config contract.Config) (contract.Producer, error)

NewProducerConn amqp producer connection

type Config struct {
	Host     string
	Username string
	Password string
	VHost    string
	Pool     *contract.Pool
}

Config 配置

func (config *Config) PoolConfig() contract.Pool

func (config *Config) String() string