6
1
mirror of https://git.mills.io/saltyim/saltyim.git synced 2024-06-16 03:48:24 +00:00

Upgrade to msgbus v0.1.18 (#153)

Co-authored-by: James Mills <prologic@shortcircuit.net.au>
Reviewed-on: https://git.mills.io/saltyim/saltyim/pulls/153
This commit is contained in:
James Mills 2022-04-05 03:10:29 +00:00
parent d90292bc8e
commit fce6c97259
4 changed files with 6 additions and 5 deletions

@ -339,13 +339,12 @@ func (cli *Client) Subscribe(ctx context.Context, extraenvs, prehook, posthook s
index := cli.state.GetIndex(inbox) + 1 // +1 to skip over the last seen message
log.Debugf("streaming inbox %s from %d ...", inbox, index)
s := bus.Subscribe(inbox, index, cli.messageHandler(extraenvs, prehook, posthook, msgs))
s.Start()
go s.Run(ctx)
log.Debugf("Connected to %s/%s", uri, inbox)
go func() {
<-ctx.Done()
s.Stop()
close(msgs)
}()

2
go.mod

@ -95,7 +95,7 @@ require (
require (
git.mills.io/prologic/bitcask v1.0.2
git.mills.io/prologic/msgbus v0.1.17
git.mills.io/prologic/msgbus v0.1.18
git.mills.io/prologic/observe v0.0.0-20210712230028-fc31c7aa2bd1
git.mills.io/prologic/useragent v0.0.0-20210714100044-d249fe7921a0
github.com/NYTimes/gziphandler v1.1.1

2
go.sum

@ -48,6 +48,8 @@ git.mills.io/prologic/msgbus v0.1.16 h1:Pm+gIJwUITTpy+OTk3jtKb/fYvg7YkS+yUh7EAfF
git.mills.io/prologic/msgbus v0.1.16/go.mod h1:ZFnDXoFvujU18Hv45pk0isCWAGjpkHpY9+/WSLzKJek=
git.mills.io/prologic/msgbus v0.1.17 h1:ncQgq6z/KGmduk6H57n4TieYBY8JIh6pM5MECisb6GU=
git.mills.io/prologic/msgbus v0.1.17/go.mod h1:ZFnDXoFvujU18Hv45pk0isCWAGjpkHpY9+/WSLzKJek=
git.mills.io/prologic/msgbus v0.1.18 h1:n6A6+fmrZnwduQE90TjZFXcxN9S1uLz0VDXmPFbCy3M=
git.mills.io/prologic/msgbus v0.1.18/go.mod h1:ZFnDXoFvujU18Hv45pk0isCWAGjpkHpY9+/WSLzKJek=
git.mills.io/prologic/observe v0.0.0-20210712230028-fc31c7aa2bd1 h1:e6ZyAOFGLZJZYL2galNvfuNMqeQDdilmQ5WRBXCNL5s=
git.mills.io/prologic/observe v0.0.0-20210712230028-fc31c7aa2bd1/go.mod h1:/rNXqsTHGrilgNJYH/8wsIRDScyxXUhpbSdNbBatAKY=
git.mills.io/prologic/useragent v0.0.0-20210714100044-d249fe7921a0 h1:MojWEgZyiugUbgyjydrdSAkHlADnbt90dXyURRYFzQ4=

@ -1,3 +1,3 @@
version https://git-lfs.github.com/spec/v1
oid sha256:093b8f14002fea44c277ccf5b4aa51ec9d2ed2d0454a4c7c887c042eaecb3173
size 29218116
oid sha256:c59542f9c90c07badd3d37b17692ae909069d3d172a1bab97fab78dc41226970
size 29225021