apache / apache/rocketmq-client-go
Unable to get SubscriptionMessageQueues
- Dominant language
- Go
- Stars
- 1.4k
- Forks
- 445
- PR merge metrics
- No merged PRs in 30d
Description
https://github.com/apache/rocketmq-client-go/blob/1d86ea68616504c6985586d2a9bd1d47c312246f/examples/consumer/pull/pull_from/main.go#L95
I'm going to implement an example of `pull_from`, I found related example in `examples` file.
But I have a doubt, why use the `FetchPublishMessageQueues` method?
`FetchSubscriptionMessageQueues` should not be used to fetch consumer queues.
Publish and Subscribe Queues should be two different queues.
But `Admin` does not provide the `FetchSubscriptionMessageQueues` interface, I think it is necessary to provide an interface to get the consumer queue.
https://github.com/apache/rocketmq-client-go/blob/1d86ea68616504c6985586d2a9bd1d47c312246f/admin/admin.go#LL33C6-L33C6

Do we need to add `FetchSubscribeMessageQueues` method in `Admin`, or do we take other methods.
```
func (a *admin) FetchSubscribeMessageQueues(ctx context.Context, topic string) ([]*primitive.MessageQueue, error) {
return a.cli.GetNameSrv().FetchSubscribeMessageQueues(utils.WrapNamespace(a.opts.Namespace, topic))
}
```
Looking forward to your reply, thank you.
Contributor guide
Assessment
This issue has not been assessed yet.