queue

type Consumer interface {
	Subject() string
	Config() string
	Subscribe(Listener) error
}

type Listener func([]byte, Consumer)

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

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

type LocalQueue struct {
	Subject string
	Config  string

	sync.Mutex
	// contains filtered or unexported fields
}

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

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

type NatsQueue struct {
	Subject string
	Config  string
}

type Producer interface {
	Subject() string
	Config() string
	Produce([]byte) error
}

type Queue interface {
	Init() error
	NewProducer() (Producer, error)
	NewConsumer() (Consumer, error)
}