mockmq

Documentation

Index

• type Config
• type MockMQ
  • func GetMockMQ(mqConnName string) (*MockMQ, error)
  • func InitMockMQ(mqConnName string, connCfg *mqenv.MQConnectorConfig, mqCfg *Config) (*MockMQ, error)
  • func (worker *MockMQ) Send(topic string, pm *mqenv.MQPublishMessage, withReply bool) (*mqenv.MQConsumerMessage, error)
  • func (worker *MockMQ) Subscribe(topic string, consumeProxy *mqenv.MQConsumerProxy)

Types

type Config

type Config struct {
	Hosts        string
	Partition    int
	PrivateTopic string
	GroupID      string
}

Config mock mq 配置参数.

type MockMQ

type MockMQ struct {
	Name string
	// contains filtered or unexported fields
}

MockMQ for test when programing

func GetMockMQ

func GetMockMQ(mqConnName string) (*MockMQ, error)

GetMockMQ 获取MockMQ.

func InitMockMQ

func InitMockMQ(mqConnName string, connCfg *mqenv.MQConnectorConfig, mqCfg *Config) (*MockMQ, error)

InitMockMQ init

func (*MockMQ) Send

func (worker *MockMQ) Send(topic string, pm *mqenv.MQPublishMessage, withReply bool) (*mqenv.MQConsumerMessage, error)

Send 发送信息.

func (*MockMQ) Subscribe

func (worker *MockMQ) Subscribe(topic string, consumeProxy *mqenv.MQConsumerProxy)

Subscribe 订阅topic.