gatewaymessageprocessor

Documentation

Index

• func New(ctx context.Context, queueName string) (serviceTY.Service, error)
• type MessageProcessor
  • func (svc *MessageProcessor) Close() error
  • func (svc *MessageProcessor) Name() string
  • func (svc *MessageProcessor) Start() error

Functions

func New

func New(ctx context.Context, queueName string) (serviceTY.Service, error)

Types

type MessageProcessor

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

func (*MessageProcessor) Close

func (svc *MessageProcessor) Close() error

Close message process engine

func (*MessageProcessor) Name

func (svc *MessageProcessor) Name() string

func (*MessageProcessor) Start

func (svc *MessageProcessor) Start() error

Start message process engine