mirror of
https://github.com/harness/drone.git
synced 2025-05-01 13:11:27 +00:00
Send retain:remove before unsubscribing
This commit is contained in:
parent
c8a97d0453
commit
3cc49ef972
@ -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 {
|
||||
|
Loading…
x
Reference in New Issue
Block a user