Mirrors
/
prologic-msgbus
mirror of https://git.mills.io/prologic/msgbus.git
6
0
Fork 0
Code Issues Projects Releases Wiki Activity

Hmmmm

This commit is contained in:
James Mills 2022-04-04 10:22:19 +10:00
parent 0581affa56
commit 061e2c7b1f
No known key found for this signature in database
GPG Key ID: AC4C014F1440EBD6
4 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
examples/examples Executable file
View File

Binary file not shown.

2
examples/hello.go
View File

@ -7,7 +7,7 @@ import (
)
func main() {
m, err := msgbus.NewMessageBus(nil)
m, err := msgbus.NewMessageBus()
if err != nil {
log.Fatal(err)
}

2
msgbus.go
View File

@ -201,7 +201,7 @@ func (subs *Subscribers) NotifyAll(message Message) int {
default:
// TODO: Drop this client?
// TODO: Retry later?
log.Warnf("cannot publish message to %s: %+v", id, message)
log.Warnf("cannot publish message %s#%d to %s", message.Topic.Name, message.ID, id)
}
}

7
msgbus_test.go
View File

@ -153,10 +153,7 @@ func TestMessageBusSubscribeFullBuffer(t *testing.T) {
require.NoError(err)
defer os.RemoveAll(testdir)
mb, err := NewMessageBus(
WithBufferLength(2),
WithLogPath(testdir),
)
mb, err := NewMessageBus(WithLogPath(testdir), WithBufferLength(2))
require.NoError(err)
topic := mb.NewTopic("hello")
@ -210,7 +207,7 @@ func TestMessageBusSubscribeWithIndex(t *testing.T) {
assert.Equal("foo", string((<-msgs).Payload))
assert.Equal("bar", string((<-msgs).Payload))
assert.Equal("baz", string((<-msgs).Payload))
//assert.Equal("baz", string((<-msgs).Payload))
}
func TestMessageBusWAL(t *testing.T) {