Skip to content

Commit

Permalink
remove unless test code
Browse files Browse the repository at this point in the history
  • Loading branch information
crossoverJie committed Nov 1, 2024
1 parent 70d75c7 commit 78df560
Showing 1 changed file with 0 additions and 9 deletions.
9 changes: 0 additions & 9 deletions pulsar/consumer_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -4727,10 +4727,6 @@ func TestLookupConsumer(t *testing.T) {
for i := 0; i < 10; i++ {
if _, err := producer.Send(ctx, &ProducerMessage{
Payload: []byte(fmt.Sprintf("hello-%d", i)),
Key: "pulsar",
Properties: map[string]string{
"key-1": "pulsar-1",
},
}); err != nil {
log.Fatal(err)
}
Expand All @@ -4744,12 +4740,7 @@ func TestLookupConsumer(t *testing.T) {
}

expectMsg := fmt.Sprintf("hello-%d", i)
expectProperties := map[string]string{
"key-1": "pulsar-1",
}
assert.Equal(t, []byte(expectMsg), msg.Payload())
assert.Equal(t, "pulsar", msg.Key())
assert.Equal(t, expectProperties, msg.Properties())
// ack message
consumer.Ack(msg)
}
Expand Down

0 comments on commit 78df560

Please sign in to comment.