Versions in this module Expand all Collapse all v2 v2.1.1 Dec 9, 2025 v2.0.0 Jun 18, 2023 Changes in this version + func New(ctx context.Context, queueName string) (serviceTY.Service, error) + type MessageProcessor struct + func (svc *MessageProcessor) Close() error + func (svc *MessageProcessor) Name() string + func (svc *MessageProcessor) Start() error