rabbitmq

Documentation

Index

• func ProducerPublish(address, exchangeName string, messageBody []byte) error
• type Consumer
  • func (c *Consumer) ReConnect()
  • func (c *Consumer) Run()
• type MQHandler
• type UpdateKubeConfig
  • func (u *UpdateKubeConfig) HandleMessage(m *amqp.Delivery) error

Functions

func ProducerPublish

func ProducerPublish(address, exchangeName string, messageBody []byte) error

Types

type Consumer

type Consumer struct {
	Address      string
	ExchangeName string
	Handler      MQHandler
	// contains filtered or unexported fields
}

func (*Consumer) ReConnect

func (c *Consumer) ReConnect()

func (*Consumer) Run

func (c *Consumer) Run()

type MQHandler

type MQHandler interface {
	HandleMessage(m *amqp.Delivery) error
}

type UpdateKubeConfig

type UpdateKubeConfig struct{}

func (*UpdateKubeConfig) HandleMessage

func (u *UpdateKubeConfig) HandleMessage(m *amqp.Delivery) error

只要实现HandleMessage方法既可以实现Handler接口