mq

type MessageQueue interface {
	Publish(ctx context.Context, topic string, body []byte) error
	Consume(ctx context.Context, topic, channel string, handler func(ctx context.Context, body []byte) error) error
	Close() error
}

type NSQ struct {
	// contains filtered or unexported fields
}

type NSQConfig struct {
	NsqdAddress         string
	ConnectToLookupd    bool
	NsqLookupdAddresses []string
	TopicPrefix         string
	*nsq.Config
}

type RabbitMQ struct {
	// contains filtered or unexported fields
}

type RabbitMQConfig struct {
	URL          string `json:"url"`
	Exchange     string `json:"exchange"`
	ExchangeType string `json:"exchange_type"`
}