mq

Documentation

Index

• func SpawnWorker(ctx context.Context, appConfig *app.ApplicationConfiguration, ...)
• type Consumer
  • func (c *Consumer) Listen(ctx context.Context) error

Functions

func SpawnWorker

func SpawnWorker(
	ctx context.Context,
	appConfig *app.ApplicationConfiguration,
	productHandler *product.Handler,
	storeHandler *store.Handler,
	id int,
)

Types

type Consumer

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

func (*Consumer) Listen

func (c *Consumer) Listen(ctx context.Context) error

Listen implements ProductConsumer.