producer

Documentation

Index

• func SendMsg(topic, msgBody string) error
• func SendMsgWithTransaction(f func() bool, topic, msgBody string) error
• type DemoListener
  • func NewDemoListener(f func() bool) *DemoListener
  • func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primitive.LocalTransactionState
  • func (dl *DemoListener) ExecuteLocalTransaction(msg *primitive.Message) primitive.LocalTransactionState

Functions

func SendMsg

func SendMsg(topic, msgBody string) error

func SendMsgWithTransaction

func SendMsgWithTransaction(f func() bool, topic, msgBody string) error

Types

type DemoListener

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

func NewDemoListener

func NewDemoListener(f func() bool) *DemoListener

func (*DemoListener) CheckLocalTransaction

func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primitive.LocalTransactionState

func (*DemoListener) ExecuteLocalTransaction

func (dl *DemoListener) ExecuteLocalTransaction(msg *primitive.Message) primitive.LocalTransactionState