mqueue

type IMessage interface {
	// GetID returns the unique identifier of this message in the underlying messaging system.
	GetID() string
	// GetContent returns the message payload in byte array format.
	GetContent() []byte
	// GetContentType returns the message's content type.
	GetContentType() string
	// GetRetries returns the number of times the message has been requeued (always 0 if unsupported by the protocol).
	GetRetries() uint
	// Requeue sends the message back to the queue to be processed after the default delay.
	Requeue() error
	// RequeueWithDelay is the same as requeue except it allows the delay to be specified.
	RequeueWithDelay(delay time.Duration) error
	// Processed marks the message as processed and removes it from the queue.
	Processed() error
}

type IRequestHandler interface {
	HandleRequest(IMessage) error
}

type NSQConfig struct {
	Lookupd      []string `mapstructure:"lookupd"`
	Nsqd         []string `mapstructure:"nsqd"`
	Topic        string   `mapstructure:"topic"`
	Channel      string   `mapstructure:"channel"`
	RequeueDelay int64    `mapstructure:"requeue_delay"`
	MaxInflight  int      `mapstructure:"max_inflight"`
	MaxAttempts  uint16   `mapstructure:"max_attempts"`
}

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

type NSQConsumerSimple struct {
	NSQConsumer
	// contains filtered or unexported fields
}

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