Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Unable to get SubscriptionMessageQueues #1048

Open
pzhx521 opened this issue May 8, 2023 · 1 comment
Open

Unable to get SubscriptionMessageQueues #1048

pzhx521 opened this issue May 8, 2023 · 1 comment

Comments

@pzhx521
Copy link

pzhx521 commented May 8, 2023

messageQueues, err := mqAdmin.FetchPublishMessageQueues(ctx, topic)

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
image

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.

@cserwen
Copy link
Member

cserwen commented Jun 21, 2023

Maybe we can add examineTopicRouteInfo just like java sdk @pzhx521

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants