Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BindConfig ¶
type BindConfig struct { ExchangeOpt *ExchangeOptions QueueOpt *QueueOptions QueueBindOpt *QueueBindOptions ConsumeOpt *ConsumeOptions }
type ConsumeOptions ¶
type ExchangeOptions ¶
type QueueBindOptions ¶
type QueueOptions ¶
type RabbitMqBroker ¶
type RabbitMqBroker struct {
// contains filtered or unexported fields
}
func New ¶
func New(c *Config) *RabbitMqBroker
func (*RabbitMqBroker) AddBinding ¶
func (b *RabbitMqBroker) AddBinding(bc *BindConfig) (string, error)
func (*RabbitMqBroker) Close ¶
func (b *RabbitMqBroker) Close()
func (*RabbitMqBroker) Connect ¶
func (b *RabbitMqBroker) Connect() error
func (*RabbitMqBroker) SendWithConfig ¶
func (b *RabbitMqBroker) SendWithConfig(id, key string, sc SendConfig) error
type SendConfig ¶
type SendConfig struct { Mandatory bool Immediate bool PublishConf *amqp.Publishing }
Click to show internal directories.
Click to hide internal directories.