Imports github.com/ThreeDotsLabs/watermill github.com/ThreeDotsLabs/watermill/message github.com/nsqio/go-nsq github.com/pkg/errors Standard library imports bytes context encoding/gob fmt sync time