Skip to content

Commit

Permalink
Merge pull request woodpecker-ci#1896 from jmccann/mq_remove_unsubscribe
Browse files Browse the repository at this point in the history
Send retain:remove before unsubscribing
  • Loading branch information
bradrydzewski authored Jan 11, 2017
2 parents c8a97d0 + 3cc49ef commit c8ddcce
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion server/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -145,8 +145,8 @@ func HandleUpdate(c context.Context, message *stomp.Message) {
}

defer func() {
client.Unsubscribe(sub)
client.Send(dest, []byte{}, stomp.WithRetain("remove"))
client.Unsubscribe(sub)
}()

select {
Expand Down

0 comments on commit c8ddcce

Please sign in to comment.