message

type AdapterAmqp interface {
	String() string
	PublishOnQueue(exchangeName, exchangeType, queueName, key, tag string, body interface{}) error
	SubscribeToQueue(exchangeName, exchangeType, queueName, key, tag string, handlerFunc AmqpConsumerFunc) error
}

type AdapterMail interface {
	String() string
	Send(address []string, body []byte) error
}

type AdapterSms interface {
	String() string
	Close()
	Send(addresses []string, template string, params map[string]string) error
	GetClient() interface{}
}

type AmqpConsumerFunc func([]byte) error