diff --git a/v1/subscriber/subscriber.go b/v1/subscriber/subscriber.go index 20f9c1d..64119f6 100644 --- a/v1/subscriber/subscriber.go +++ b/v1/subscriber/subscriber.go @@ -276,7 +276,7 @@ func (p *API) GetClientIDByResource(resource string) (clientIDs []uuid.UUID) { defer p.SubscriberStore.RUnlock() for _, subs := range p.SubscriberStore.Store { for _, sub := range subs.SubStore.Store { - if sub.GetResource() == resource { + if strings.Contains(sub.GetResource(), resource) { clientIDs = append(clientIDs, subs.ClientID) } }