queue

package

v0.0.0-...-56ec27c Latest Latest Go to latest Published: Nov 5, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewQueue(cfg *config.Configuration) (interfaces.Queue, error)

type Queue struct {
	Conn    rmq.Connection
	Events  rmq.Queue
	Storage interfaces.Storage
	Logger  *logger.Logger
}

func (q *Queue) Consume(delivery rmq.Delivery)

Internal consumert method.

func (q *Queue) ProduceEvent(e structs.QueueEvent) error

func (q *Queue) RunConsumer(storageI interfaces.Storage, logger *logger.Logger) error

func (q *Queue) StopConsumer() error