Versions in this module Expand all Collapse all v1 v1.0.0 Dec 30, 2020 Changes in this version + const LoadBalanceMethodLoop + const WorkResponseSuccess + type Handler struct + func NewHandler(consumeConfig model.ConsumeConfig) Handler + func (h *Handler) HandleMessage(message *nsq.Message) error + func (h *Handler) LogFailedMessage(message nsq.Message) + type Proxy struct + func NewProxy() *Proxy + func (p *Proxy) GetStop() int + func (p *Proxy) IsStop() bool + func (p *Proxy) Run() + func (p *Proxy) SetExitFlag() + func (p *Proxy) Stop() + func (p *Proxy) StopConsume(consumeConfig *model.ConsumeConfig)
Go to main page