rabbit

type Connector interface {
	Connect() (MqContext, error)
	UseConnection(connection *amqp.Connection)
}

type Consumer interface {
	StartConsuming(consumerTag string) error
	StartConsumingBy(consumerTag string, handle Handle) error
}

type ContextBuilder interface {
	WithExchange(name, exchangeType string) MqContext
	WithQueue(queueName, key string) MqContext
	WithHandle(handle Handle) MqContext
}

type FromJSON func(string) (interface{}, error)

type Handle func(*Message)

type Message struct {
	ID          string
	MessageType string
	Body        string
	ContentType string
	Created     time.Time
}

type MqContext interface {
	ContextBuilder
	Connector
	Publisher
	Consumer
}

type Publisher interface {
	Publish(message Message) error
}

type ToJSON func(interface{}) ([]byte, error)