* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements.

NewMockInnerConsumer creates a new mock instance.

NewMockInnerProducer creates a new mock instance.

NewMockNamesrvs creates a new mock instance.

NewMockRMQClient creates a new mock instance.

NewNamesrv init Namesrv from namesrv addr string.

BrokerData BrokerData.

remotingClient callback TransactionProducer.

MockInnerConsumer is a mock of InnerConsumer interface.

MockInnerConsumerMockRecorder is the mock recorder for MockInnerConsumer.

MockInnerProducer is a mock of InnerProducer interface.

MockInnerProducerMockRecorder is the mock recorder for MockInnerProducer.

MockNamesrvs is a mock of Namesrvs interface.

MockNamesrvsMockRecorder is the mock recorder for MockNamesrvs.

MockRMQClient is a mock of RMQClient interface.

MockRMQClientMockRecorder is the mock recorder for MockRMQClient.

QueueData QueueData.

key is topic, value is TopicPublishInfo.

TopicRouteData TopicRouteData.

go:generate mockgen -source namesrv.go -destination mock_namesrv.go -self_package github.com/swift9/rocketmq-client-go/internal --package internal Namesrvs.

go:generate mockgen -source client.go -destination mock_client.go -self_package github.com/swift9/rocketmq-client-go/internal --package internal RMQClient.