queue

type CloseListener interface {
	OnClose() error
}

type Confirmation interface {
	Confirm() error
	Reject() error
}

type Delivery struct {
	Redelivered bool
}

type DestinationConfig struct {
	RoutingKey string                `json:"name"`
	QueueName  string                `json:"queue"`
	Exchange   string                `json:"exchange"`
	Attributes []string              `json:"attributes"`
	Filters    []FilterConfiguration `json:"filters"`
}

type FilterConfiguration struct {
	Metadata FilterSpec `json:"metadata"`
	Message  FilterSpec `json:"message"`
}

type FilterFieldsConfig struct {
	FieldName     string
	ExpectedValue string
	Operation     FilterOperation
}

type FilterOperation string

type FilterSpec struct {
	Filters []FilterFieldsConfig
}

type Monitor interface {
	Unsubscribe() error
}

type RouterConfig struct {
	Queues map[string]DestinationConfig `json:"queues"`
}