File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -24,12 +24,13 @@ import (
2424 "testing"
2525 "time"
2626
27+ "github.com/stretchr/testify/assert"
28+
2729 "github.com/apache/pulsar-client-go/pulsar/internal"
2830 pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
2931 "github.com/apache/pulsar-client-go/pulsaradmin"
3032 "github.com/apache/pulsar-client-go/pulsaradmin/pkg/admin/config"
3133 "github.com/apache/pulsar-client-go/pulsaradmin/pkg/utils"
32- "github.com/stretchr/testify/assert"
3334)
3435
3536func TestMultiTopicConsumerReceive (t * testing.T ) {
@@ -366,6 +367,10 @@ func (dummyConnection) IsProxied() bool {
366367 return false
367368}
368369
370+ func (dummyConnection ) Closed () bool {
371+ return false
372+ }
373+
369374func TestMultiTopicAckIDListTimeout (t * testing.T ) {
370375 topic := fmt .Sprintf ("multiTopicAckIDListTimeout%v" , time .Now ().UnixNano ())
371376 assert .NoError (t , createPartitionedTopic (topic , 5 ))
You can’t perform that action at this time.
0 commit comments