Remove logging
This commit is contained in:
parent
65a880fadd
commit
1340e81235
@ -18,8 +18,6 @@ func TestBroker(t *testing.T) {
|
|||||||
count := 10
|
count := 10
|
||||||
|
|
||||||
fn := func(p broker.Publication) error {
|
fn := func(p broker.Publication) error {
|
||||||
m := p.Message()
|
|
||||||
t.Logf("Received message id %s %+v for topic %s", m.Header["id"], m, p.Topic())
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -37,7 +35,6 @@ func TestBroker(t *testing.T) {
|
|||||||
Body: []byte(`hello world`),
|
Body: []byte(`hello world`),
|
||||||
}
|
}
|
||||||
|
|
||||||
t.Logf("Sending message %d %+v for topic %s", i, message, topic)
|
|
||||||
if err := b.Publish(topic, message); err != nil {
|
if err := b.Publish(topic, message); err != nil {
|
||||||
t.Fatalf("Unexpected error publishing %d", i)
|
t.Fatalf("Unexpected error publishing %d", i)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user