change the batchSend

automatically splits the frames. Removes the messages too big for the frame. Add the batch result to give more control to the user Signed-off-by: Gabriele Santomaggio <[email protected]>
rabbitmq · Dec 3, 2024 · b1001e1 · b1001e1
1 parent cee445a
commit b1001e1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/stream/producer_test.go b/pkg/stream/producer_test.go
@@ -359,7 +359,7 @@ var _ = Describe("Streaming Producers", func() {
 		Expect(producer.Close()).To(HaveOccurred())
 	})
 
-	It("Smart Send Split frame/BatchSize", Focus, func() {
+	It("Smart Send Split frame/BatchSize", func() {
 		producer, err := testEnvironment.NewProducer(testProducerStream,
 			NewProducerOptions().SetBatchSize(50))
 		Expect(err).NotTo(HaveOccurred())