zoulinz

fix when tcp connection fails, re-queue the msg back to channel, the channel is already full. Not able to create the worker for de-queue

There is a bug here. if len(m.config.HeaderRewrite) > 0 { for _, f := range m.config.HeaderRewrite { value := proto.Header(payload, f.header) if len(value) == 0 { break