receivedPeekBatch, err := queue.PeekBatch(context.Background(), 3)