Versions in this module Expand all Collapse all v0 v0.4.2 Dec 15, 2022 v0.4.1 Dec 15, 2022 Changes in this version + type Config struct + Host string + Password string + Port string + UserName string + VHost string + func (c *Config) GetUri() string + type ConfigBuilder struct + func NewConfigBuilder() *ConfigBuilder + func (c *ConfigBuilder) Build() *Config + func (c *ConfigBuilder) SetHost(host string) + func (c *ConfigBuilder) SetPassword(password string) + func (c *ConfigBuilder) SetPort(port string) + func (c *ConfigBuilder) SetUserName(userName string) + func (c *ConfigBuilder) SetVHost(vHost string) + type Connection struct + NotifyClose chan *amqp091.Error + NotifyConfirm chan amqp091.Confirmation + func NewConnection(name string, config Config) *Connection + func (c *Connection) Channel() (*amqp091.Channel, error) + func (c *Connection) Close() + func (c *Connection) Connect() error + func (c *Connection) GetConnection(name string) *Connection + func (c *Connection) OnClosedConnection() error + func (c *Connection) Reconnect() error + type Consumer interface + Args func() amqp091.Table + AutoAck func() bool + Connection func() *Connection + Consumer func() string + Exclusive func() bool + NoLocal func() bool + NoWait func() bool + Queue func() string + SetArgs func(args amqp091.Table) + SetAutoAck func(autoAck bool) + SetConnection func(connection *Connection) + SetConsumer func(consumer string) + SetExclusive func(exclusive bool) + SetNoLocal func(noLocal bool) + SetNoWait func(noWait bool) + SetQueue func(queue string) + StartConsuming func(queue string, d func(messages amqp091.Delivery)) + func NewConsumer(connection *Connection) Consumer + type Exchange interface + Args func() amqp091.Table + AutoDelete func() bool + Conn func() *Connection + Declare func(name string, kind string) error + Durable func() bool + Internal func() bool + Kind func() string + Name func() string + NoWait func() bool + SetArgs func(args amqp091.Table) + SetAutoDelete func(autoDelete bool) + SetConn func(conn *Connection) + SetDurable func(durable bool) + SetInternal func(internal bool) + SetKind func(kind string) + SetName func(name string) + SetNoWait func(noWait bool) + func NewExchange(conn *Connection) Exchange + func NewExchangeWithName(conn *Connection, name string) Exchange + func NewExchangeWithParams(conn *Connection, name string, kind string) Exchange + type Publisher interface + Connection func() *Connection + Exchange func() string + Immediate func() bool + Key func() string + Mandatory func() bool + Message func() amqp091.Publishing + Publish func(ctx context.Context, exchange string, key string, msg amqp091.Publishing) error + SetConnection func(connection *Connection) + SetExchange func(exchange string) + SetImmediate func(immediate bool) + SetKey func(key string) + SetMandatory func(mandatory bool) + SetMessage func(message amqp091.Publishing) + func NewPublisher(connection *Connection) Publisher + type Queue interface + Args func() amqp091.Table + AutoDelete func() bool + Bind func(name string, key string, exchange string) error + Connection func() *Connection + Declare func(name string) (amqp091.Queue, error) + Durable func() bool + Exchange func() string + Exclusive func() bool + Key func() string + Name func() string + NoWait func() bool + SetArgs func(args amqp091.Table) + SetAutoDelete func(autoDelete bool) + SetConnection func(con *Connection) + SetDurable func(durable bool) + SetExchange func(exchange string) + SetExclusive func(exclusive bool) + SetKey func(key string) + SetName func(name string) + SetNoWait func(noWait bool) + func NewQueue(connection *Connection) Queue
Go to main page