contracts

Documentation

Index

• type Connection
• type ErrorHandler
• type NamedPayload
• type WithConnection
• type Worker

Types

type Connection

type Connection interface {
	Consume(concurrency int, exit chan struct{}, handler ErrorHandler) error
	Stop() error
	Dispatch(payload interface{}, delay ...time.Duration) error
}

type ErrorHandler

type ErrorHandler func(error)

type NamedPayload

type NamedPayload interface {
	PayloadName() string
}

type WithConnection

type WithConnection interface {
	QueueConnection() string
}

type Worker

type Worker interface {
	Run(done chan struct{}, handler ErrorHandler) error
	Close() error
}