diff --git a/broker.go b/broker.go index 644ea13..b93e660 100644 --- a/broker.go +++ b/broker.go @@ -152,7 +152,7 @@ func (b *Broker) ReceivePublish(sessionID int64, publish *messages.Publish) (*Pu event := messages.NewEvent(subscription.ID, publicationID, nil, publish.Args(), publish.KwArgs()) result.Event = event for _, subscriber := range subscription.Subscribers { - result.recipients = append(result.recipients, subscriber) + result.Recipients = append(result.Recipients, subscriber) } } diff --git a/types.go b/types.go index 9c9f001..04cb88f 100644 --- a/types.go +++ b/types.go @@ -54,6 +54,6 @@ type Subscription struct { type Publication struct { Event *messages.Event - recipients []int64 + Recipients []int64 Ack *MessageWithRecipient }