Documentation ¶
Index ¶
- func MustNewListener(listenerConf RabbitListenerConf, handler ConsumeHandler) queue.MessageQueue
- type Admin
- type ConsumeHandle
- type ConsumeHandler
- type ConsumerConf
- type ExchangeConf
- type QueueConf
- type RabbitConf
- type RabbitListener
- type RabbitListenerConf
- type RabbitMqSender
- type RabbitSenderConf
- type Sender
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MustNewListener ¶
func MustNewListener(listenerConf RabbitListenerConf, handler ConsumeHandler) queue.MessageQueue
Types ¶
type Admin ¶
type Admin struct {
// contains filtered or unexported fields
}
func MustNewAdmin ¶
func MustNewAdmin(rabbitMqConf RabbitConf) *Admin
func (*Admin) DeclareExchange ¶
func (q *Admin) DeclareExchange(conf ExchangeConf, args amqp.Table) error
type ConsumeHandle ¶
type ConsumeHandler ¶
type ConsumerConf ¶
type ConsumerConf struct { Name string AutoAck bool `json:",default=true"` Exclusive bool `json:",default=false"` // Set to true, which means that messages sent by producers in the same connection // cannot be delivered to consumers in this connection. NoLocal bool `json:",default=false"` // Whether to block processing NoWait bool `json:",default=false"` }
type ExchangeConf ¶
type RabbitConf ¶
type RabbitListener ¶
type RabbitListener struct {
// contains filtered or unexported fields
}
func (RabbitListener) Start ¶
func (q RabbitListener) Start()
func (RabbitListener) Stop ¶
func (q RabbitListener) Stop()
type RabbitListenerConf ¶
type RabbitListenerConf struct { RabbitConf ListenerQueues []ConsumerConf }
type RabbitMqSender ¶
type RabbitMqSender struct { ContentType string // contains filtered or unexported fields }
type RabbitSenderConf ¶
type RabbitSenderConf struct { RabbitConf ContentType string `json:",default=text/plain"` // MIME content type }
type Sender ¶
func MustNewSender ¶
func MustNewSender(rabbitMqConf RabbitSenderConf) Sender
Click to show internal directories.
Click to hide internal directories.