Skip to content

Commit

Permalink
Merge pull request #42 from xconnio/recipientspub
Browse files Browse the repository at this point in the history
make recipients field public in Publication
  • Loading branch information
om26er authored Jun 30, 2024
2 parents a5b46a0 + 1dace03 commit 0fe0eeb
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion broker.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
}

Expand Down
2 changes: 1 addition & 1 deletion types.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,6 @@ type Subscription struct {

type Publication struct {
Event *messages.Event
recipients []int64
Recipients []int64
Ack *MessageWithRecipient
}

0 comments on commit 0fe0eeb

Please sign in to comment.