rabbit

Feb 25, 2021

Changes in this version

+ const DefaultChannelNum

+ const DefaultConnNum

+ const DefaultHost

+ const RabbitAttempt

+ type Channel struct

+ func NewChannel(ch *amqp.Channel) *Channel

+ func (c *Channel) Consume(name string) (<-chan amqp.Delivery, error)

+ func (c *Channel) ExchangeDeclare(ex *Exchange) error

+ func (c *Channel) Publish(data *PublishData) error

+ func (c *Channel) QueueBind(queueName, key, exchangeName string, args amqp.Table) error

+ func (c *Channel) QueueDeclare(queue *Queue) (amqp.Queue, error)

+ type ChannelPool struct

+ func NewChannelPool(pool *list.List) *ChannelPool

+ func (p *ChannelPool) Get() (*Channel, error)

+ func (p *ChannelPool) Release(channel *Channel)

+ type ChannelService interface

+ Publish func(data *PublishData) error

+ type ConnPoolOptions struct

+ ChannelNum int

+ ConnNum int

+ Url string

+ type Connection struct

+ func NewConnection(config *ConnectionConfig) *Connection

+ func (c *Connection) GetChannelPool() *ChannelPool

+ type ConnectionConfig struct

+ ChanNum int

+ Url string

+ type ConnectionPool struct

+ func NewConnectionPool(opts *ConnPoolOptions) *ConnectionPool

+ func (c *ConnectionPool) Get() (*Connection, error)

+ func (c *ConnectionPool) Release(conn *Connection)

+ type Consumer interface

+ Consume func(name string) error

+ type ConsumerService struct

+ Rabbit RabbitService

+ func NewConsumerService(rabbit RabbitService) *ConsumerService

+ func (c *ConsumerService) Consume(name string) error

+ func (c *ConsumerService) Listen(name string)

+ type Exchange struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ Kind string

+ Name string

+ NoWait bool

+ type Job interface

+ func NewJobService(m *Message, rabbitService RabbitService) Job

+ type JobService struct

+ func (j *JobService) Ack() error

+ func (j *JobService) Attempt() int

+ func (j *JobService) Retry(ctx context.Context) error

+ type Message struct

+ Attempt int

+ Body []byte

+ ContentType string

+ D amqp.Delivery

+ Headers amqp.Table

+ ID string

+ RoutingKey string

+ type Options struct

+ Host string

+ MaxChannels int

+ MaxConnection int

+ type Producer interface

+ Publish func(ctx context.Context, exchange *Exchange, message *Message) error

+ func NewProducerService(rabbit RabbitService) Producer

+ type ProducerService struct

+ Rabbit RabbitService

+ func (p *ProducerService) Publish(ctx context.Context, exchange *Exchange, message *Message) error

+ type PublishData struct

+ Exchange string

+ Immediate bool

+ Key string

+ Mandatory bool

+ Msg *amqp.Publishing

+ type Queue struct

+ Args amqp.Table

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool

+ type Rabbit struct

+ func NewRabbit(opts *Options) *Rabbit

+ func (r *Rabbit) BindQueue(ch *Channel, exchangeName, key, queueName string) error

+ func (r *Rabbit) ExchangeDeclare(ch *Channel, exchange *Exchange) error

+ func (r *Rabbit) GetConnectionPool() *ConnectionPool

+ func (r *Rabbit) QueueDeclare(ch *Channel, queue *Queue) error

+ type RabbitService interface

+ BindQueue func(ch *Channel, exchangeName, key, queueName string) error

+ ExchangeDeclare func(ch *Channel, exchange *Exchange) error

+ GetConnectionPool func() *ConnectionPool

+ QueueDeclare func(ch *Channel, queue *Queue) error