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

just for test.

NewMockInnerConsumer creates a new mock instance.

NewMockInnerProducer creates a new mock instance.

NewMockRMQClient creates a new mock instance.

NewNamesrv init Namesrv from namesrv addr string.

BrokerData BrokerData.

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.

MockRMQClient is a mock of RMQClient interface.

MockRMQClientMockRecorder is the mock recorder for MockRMQClient.

Namesrvs rocketmq namesrv instance.

QueueData QueueData.

key is topic, value is TopicPublishInfo.

TopicRouteData TopicRouteData.

go:generate mockgen -source client.go -destination mock_client.go --package internal RMQClient.