Documentation
¶
Index ¶
Constants ¶
View Source
const LoadBalanceMethodLoop = "loop"
View Source
const WorkResponseSuccess = "200"
响应成功
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
func NewHandler ¶
func NewHandler(consumeConfig model.ConsumeConfig) Handler
func (*Handler) HandleMessage ¶
处理收到的订阅的消息 返回error就会重新入队，返回nil则不会
func (*Handler) LogFailedMessage ¶
func (h *Handler) LogFailedMessage(message nsq.Message)
处理失败时会调用此方法 连续失败五次次，第六次时在go-nsq客户端giving up时会执行
type Proxy ¶
type Proxy struct {
// contains filtered or unexported fields
}
func (*Proxy) SetExitFlag ¶
func (p *Proxy) SetExitFlag()
Source Files
Click to show internal directories.
Click to hide internal directories.