consumer

Documentation

Index

• func StartRefundTicketConsumer()
• type PushConsumer
  • func (c *PushConsumer) Shutdown() error
  • func (c *PushConsumer) Start() error
• type PushConsumerInterface

Functions

func StartRefundTicketConsumer

func StartRefundTicketConsumer()

Types

type PushConsumer

type PushConsumer struct {
	F         func(msg string)
	GroupName string
	Topic     string
	Address   string
	// contains filtered or unexported fields
}

Implement push consumer.

func (*PushConsumer) Shutdown

func (c *PushConsumer) Shutdown() error

func (*PushConsumer) Start

func (c *PushConsumer) Start() error

type PushConsumerInterface

type PushConsumerInterface interface {
	Start() error
	Shutdown() error
}

Define push consumer interface.