rmq

Documentation

Index

• func NewUserAssetEventMsg(txRmqProducerClient rocketmq.TransactionProducer, ...) domain.IUserAssetEventMsgRepository
• func NewUserAssetEventMsgLister(userAssetEventRepository domain.IUserAssetEventRepository) domain.IUserAssetEventMsgListener
• type UserAssetEventMsg
  • func (m *UserAssetEventMsg) SendUserAssetChangeMsgTx(ctx context.Context, topicName, tagName string, userId int64, ...) (err error)
• type UserAssetEventMsgLister
  • func (m *UserAssetEventMsgLister) CheckLocalTransaction(msg *primitive.MessageExt) primitive.LocalTransactionState
  • func (m *UserAssetEventMsgLister) ExecuteLocalTransaction(msg *primitive.Message) primitive.LocalTransactionState

Functions

func NewUserAssetEventMsg

func NewUserAssetEventMsg(txRmqProducerClient rocketmq.TransactionProducer, userAssetEventRepository domain.IUserAssetEventRepository) domain.IUserAssetEventMsgRepository

func NewUserAssetEventMsgLister

func NewUserAssetEventMsgLister(userAssetEventRepository domain.IUserAssetEventRepository) domain.IUserAssetEventMsgListener

Types

type UserAssetEventMsg

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

func (*UserAssetEventMsg) SendUserAssetChangeMsgTx

func (m *UserAssetEventMsg) SendUserAssetChangeMsgTx(ctx context.Context, topicName, tagName string, userId int64, event *station.BizEventAssetChange, handler primitive.TxHandler) (err error)

type UserAssetEventMsgLister

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

func (*UserAssetEventMsgLister) CheckLocalTransaction

func (m *UserAssetEventMsgLister) CheckLocalTransaction(msg *primitive.MessageExt) primitive.LocalTransactionState

CheckLocalTransaction check user asset event msg is ok

func (*UserAssetEventMsgLister) ExecuteLocalTransaction

func (m *UserAssetEventMsgLister) ExecuteLocalTransaction(msg *primitive.Message) primitive.LocalTransactionState

Deprecated: ExecuteLocalTransaction do nothing just adapter older interface, use primitive.Message.WithTxHandler instead