nsq

type Consumer struct {
	// contains filtered or unexported fields
}

type ConsumerConfig struct {
	ListenAddress []string
	Prefix        string
	StopTimeout   time.Duration
}

type ConsumerHandler struct {
	Topic       string
	Channel     string
	Concurrent  int
	MaxAttempts uint16
	MaxInFlight int
	Enable      bool

	Handler func(message IMessage) error
}

type IMessage interface {
	// Finish sends a FIN command to the nsqd which
	// sent this message
	Finish()
	// RequeueWithoutBackoff sends a REQ command to the nsqd which
	// sent this message, using the supplied delay.
	//
	// Notably, using this method to respond does not trigger a backoff
	// event on the configured Delegate.
	RequeueWithoutBackoff(delay time.Duration)
	// Requeue sends a REQ command to the nsqd which
	// sent this message, using the supplied delay.
	Requeue(delay time.Duration)
	// GetAttempts will get the current attempts
	GetAttempts() uint16
	// GetBody will get the body value
	GetBody() []byte
}

type Message struct {
	*nsq.Message
}

type Publisher struct {
	// contains filtered or unexported fields
}