queue

type Config struct {
	Type string      `mapstructure:"type"`
	Nats nats.Config `mapstructure:"nats"`
}

type Publisher interface {
	Pub(channel string, msg *message.Message) error
}

type Subscriber interface {
	Sub(channel string, action func(msg *message.Message)) error
}