You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
rocketmq-client-go/examples/consumer/pull/pull_from/main.go
Line 95 in 1d86ea6
I'm going to implement an example of
pull_from
, I found related example inexamples
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 theFetchSubscriptionMessageQueues
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 inAdmin
, or do we take other methods.Looking forward to your reply, thank you.
The text was updated successfully, but these errors were encountered: