Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
deprecated
func (m *UserAssetEventMsgLister) ExecuteLocalTransaction(msg *primitive.Message) primitive.LocalTransactionState
Deprecated: ExecuteLocalTransaction do nothing just adapter older interface, use primitive.Message.WithTxHandler instead
Source Files
Click to show internal directories.
Click to hide internal directories.