workers

type BaseMessageWorker struct {
	Bus *bus.Bus

	MessageWorker
	// contains filtered or unexported fields
}

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

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