fix nats broker tests

centrifugal · Oct 1, 2020 · 1fedbd4 · 1fedbd4
1 parent c983505
commit 1fedbd4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/internal/natsbroker/broker_test.go b/internal/natsbroker/broker_test.go
@@ -28,7 +28,7 @@ func BenchmarkNatsEnginePublish(b *testing.B) {
 	pub := &centrifuge.Publication{Data: rawData}
 	b.ResetTimer()
 	for i := 0; i < b.N; i++ {
-		err := broker.Publish("channel", pub, &centrifuge.ChannelOptions{HistorySize: 0, HistoryLifetime: 0})
+		_, err := broker.Publish("channel", pub, centrifuge.PublishOptions{})
 		if err != nil {
 			panic(err)
 		}
@@ -43,7 +43,7 @@ func BenchmarkNatsEnginePublishParallel(b *testing.B) {
 	b.ResetTimer()
 	b.RunParallel(func(pb *testing.PB) {
 		for pb.Next() {
-			err := broker.Publish("channel", pub, &centrifuge.ChannelOptions{HistorySize: 0, HistoryLifetime: 0})
+			_, err := broker.Publish("channel", pub, centrifuge.PublishOptions{})
 			if err != nil {
 				panic(err)
 			}