diff --git a/broker/mock/mock_test.go b/broker/mock/mock_test.go index 9e8318c4..16513b40 100644 --- a/broker/mock/mock_test.go +++ b/broker/mock/mock_test.go @@ -18,8 +18,6 @@ func TestBroker(t *testing.T) { count := 10 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 } @@ -37,7 +35,6 @@ func TestBroker(t *testing.T) { Body: []byte(`hello world`), } - t.Logf("Sending message %d %+v for topic %s", i, message, topic) if err := b.Publish(topic, message); err != nil { t.Fatalf("Unexpected error publishing %d", i) }