clinci

type Config struct {
	Durable    bool
	AutoDelete bool
	AutoAck    bool
	Internal   bool
	NoLocal    bool
	NoWait     bool
	Args       amqp.Table
}

type Configurable interface {
	Name() string
	Config() *Config
}

type Consumer interface {
	Configurable
}

type Dispatcher interface {
	Dispatch(pub Publishable) error
}

type Emitter interface {
	Declare(event Event) error
	DeclareAll(events []Event) error
	Dispatcher
}

type Event interface {
	Configurable
	Kind() string
}

type EventListener struct {
	Event     Event
	Listeners []Listener
}

type Listener interface {
	Task
	Queuer() Queuer
	Consumer() Consumer
}

type Publishable interface {
	Name() string
	Data() ([]byte, error)
	Routing
}

type Queuer interface {
	SetName(name string)
	Configurable
}

type Routing interface {
	Key() string
}

type Task interface {
	Routing
	Handle(data []byte) error
}

type Worker interface {
	Declare(el *EventListener) error
	DeclareAll(eventListeners []*EventListener) error
	Listen() error
}