messenger

type MenssengerOption struct {
	Host      string
	Auth      bool
	Zone      string
	Username  string
	Password  string
	Topics    map[string]string
	Heartbeat int
	Active    bool
	Qos       int
}

type Messenger interface {
	Sent(ctx context.Context, payload SentPayload) error
	GetConnect(ctx context.Context) interface{}
	GetTopic(ctx context.Context, key string) string
	GetConsume(ctx context.Context, channel interface{}) (interface{}, error)
	GetActive(ctx context.Context) bool
}

type Rabbit struct {
	Connect *amqp.Connection
	Topics  map[string]string

	Active  bool
	Qos     int
	Channel *amqp.Channel
	// contains filtered or unexported fields
}

type SentPayload struct {
	Topic    string
	Message  string
	Priority uint8
	Channel  interface{}
}