service

Documentation

Index

• Variables
• type MqService
  • func NewMQ() *MqService
  • func (s *MqService) CountConsumerMessages(consumerId string, messageName string) (int, error)
  • func (s *MqService) DeclareConsumer(consumerId string, messageName string, consumerRouteKey string) error
  • func (s *MqService) DeclareExchange(name string, mode string, durable bool) error
  • func (s *MqService) DeleteExchange(name string) error
  • func (s *MqService) Publish(body string, exchangeName string, token string, routeKey string) (err error)
  • func (s *MqService) ReloadExchange(messageName string) error
  • func (s *MqService) ReloadExchanges() error
  • func (s *MqService) StopAllConsumer()
  • func (s *MqService) UnbindStopConsumer(consumerId string, messageName string, consumerRouteKey string) error

Variables

var MQ = NewMQ()

Types

type MqService

type MqService struct {
}

func NewMQ

func NewMQ() *MqService

func (*MqService) CountConsumerMessages

func (s *MqService) CountConsumerMessages(consumerId string, messageName string) (int, error)

func (*MqService) DeclareConsumer

func (s *MqService) DeclareConsumer(consumerId string, messageName string, consumerRouteKey string) error

declare a consumer

func (*MqService) DeclareExchange

func (s *MqService) DeclareExchange(name string, mode string, durable bool) error

declare a Exchange

func (*MqService) DeleteExchange

func (s *MqService) DeleteExchange(name string) error

delete a exchange

func (*MqService) Publish

func (s *MqService) Publish(body string, exchangeName string, token string, routeKey string) (err error)

publish message to mq

func (*MqService) ReloadExchange

func (s *MqService) ReloadExchange(messageName string) error

reload one exchange

func (*MqService) ReloadExchanges

func (s *MqService) ReloadExchanges() error

reload RabbitMQ all exchanges

func (*MqService) StopAllConsumer

func (s *MqService) StopAllConsumer()

stop all consumer

func (*MqService) UnbindStopConsumer

func (s *MqService) UnbindStopConsumer(consumerId string, messageName string, consumerRouteKey string) error

stop consumer and unbind consumer to exchange