Fix msgbus tests
This commit is contained in:
rodič
abe0d5e972
revize
09f09fc0e2
|
@ -206,7 +206,7 @@ func TestServeHTTPSimple(t *testing.T) {
|
|||
|
||||
var msg *Message
|
||||
json.Unmarshal(w.Body.Bytes(), &msg)
|
||||
assert.Equal(msg.ID, uint64(0))
|
||||
assert.Equal(msg.ID, 0)
|
||||
assert.Equal(msg.Topic.Name, "hello")
|
||||
assert.Equal(msg.Payload, []byte("hello world"))
|
||||
}
|
||||
|
@ -263,7 +263,7 @@ func TestServeHTTPSubscriber(t *testing.T) {
|
|||
defer r.Body.Close()
|
||||
|
||||
msg := <-msgs
|
||||
assert.Equal(msg.ID, uint64(0))
|
||||
assert.Equal(msg.ID, 0)
|
||||
assert.Equal(msg.Topic.Name, "hello")
|
||||
assert.Equal(msg.Payload, []byte("hello world"))
|
||||
}
|
||||
|
@ -309,7 +309,7 @@ func TestServeHTTPSubscriberReconnect(t *testing.T) {
|
|||
defer r.Body.Close()
|
||||
|
||||
msg := <-msgs
|
||||
assert.Equal(msg.ID, uint64(0))
|
||||
assert.Equal(msg.ID, 0)
|
||||
assert.Equal(msg.Topic.Name, "hello")
|
||||
assert.Equal(msg.Payload, []byte("hello world"))
|
||||
}
|
||||
|
|
Načítá se…
Odkázat v novém úkolu