workers

Documentation

Index

• type BaseMessageWorker
  • func NewBaseMessageWorker(b *bus.Bus, queue string) *BaseMessageWorker
  • func (w *BaseMessageWorker) Run() error
  • func (w *BaseMessageWorker) Stop() error
• type MessageWorker
• type Worker

Types

type BaseMessageWorker

type BaseMessageWorker struct {
	Bus *bus.Bus

	MessageWorker
	// contains filtered or unexported fields
}

func NewBaseMessageWorker

func NewBaseMessageWorker(b *bus.Bus, queue string) *BaseMessageWorker

func (*BaseMessageWorker) Run

func (w *BaseMessageWorker) Run() error

func (*BaseMessageWorker) Stop

func (w *BaseMessageWorker) Stop() error

type MessageWorker

type MessageWorker interface {
	Process(*message.Message) error
	Stop() error
}

type Worker

type Worker interface {
	Run() error
	Stop() error
}