consumer

Documentation

Index

• func RegisterUserAssetEvent(opts map[string]*subscriber.RmqPushConsumerOptions, ...) (mapSubscribeHandler map[string]subscriber.IRocketMQConsumerSubscribeHandler)
• type UserAssetChangeEvent
  • func (m *UserAssetChangeEvent) SubMsgsHandle(ctx context.Context, msgs ...*primitive.MessageExt) (res consumer.ConsumeResult, err error)

Functions

func RegisterUserAssetEvent

func RegisterUserAssetEvent(opts map[string]*subscriber.RmqPushConsumerOptions, userAssetEventUseCase domain.IUserAssetEventUseCase) (mapSubscribeHandler map[string]subscriber.IRocketMQConsumerSubscribeHandler)

Register event handler

Types

type UserAssetChangeEvent

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

func (*UserAssetChangeEvent) SubMsgsHandle

func (m *UserAssetChangeEvent) SubMsgsHandle(ctx context.Context, msgs ...*primitive.MessageExt) (res consumer.ConsumeResult, err error)