queues

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

type Handler func(msg Message) error

type Message interface {
	// Body - provides the message body.
	Body() []byte
	// Timestamp - provides the message timestamp.
	Timestamp() int64
	// AttemptsCount provides message attempts count.
	AttemptsCount() uint16
	// QueueAddr - provides queue addr.
	QueueAddr() string
	// HasResponded - indicates whether or not this message has been responded to.
	HasResponded() bool
	// DisableAutoResponse - disables the automatic response that would normally be sent when a handler.
	DisableAutoResponse()
	// Touch - sends a touch command.
	Touch()
	// RequeueWithoutBackoff - sent this message, using the supplied delay.
	RequeueWithoutBackoff(delay time.Duration)
	// Finish - sends a finish command.
	Finish()
	// Context - provides message context.
	Context() context.Context
	// Subject - provides the message Subject.
	Subject() string
}

type Pinger interface {
	// Ping - ping queue,
	Ping(ctx context.Context) error
}

type Publisher interface {
	// Publish - publish message.
	Publish(ctx context.Context, subj string, body []byte) error
}

type QueueManager interface {
	Publisher
	Pinger
	// Subscribe - subscribe to subj. Return Subscriber.
	Subscribe(ctx context.Context, subj string, handler Handler) (Subscriber, error)
	// Unsubscribe - unsubscribe Queue.
	Unsubscribe(ctx context.Context)
	// Stop - stop Queue.
	Stop(ctx context.Context)
}

type Subscriber interface {
	// Unsubscribe - unsubscribe Subscriber.
	Unsubscribe(ctx context.Context) error
	// Stop - stop Subscriber.
	Stop(ctx context.Context)
}