Merge pull request #1896 from jmccann/mq_remove_unsubscribe

Send retain:remove before unsubscribing
This commit is contained in:
Brad Rydzewski 2017-01-11 06:42:15 +04:00 committed by GitHub
commit c8ddcce703

View file

@ -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 {