From 4b253282a5d8898ddd03924fa808ce538ea3a77a Mon Sep 17 00:00:00 2001
From: Ramachandran A G <106139410+ag-ramachandran@users.noreply.github.com>
Date: Thu, 5 Sep 2024 08:19:54 +0530
Subject: [PATCH] * Change versions of java lib and bump version for worker lib
 (#55)

* Change versions of java lib and bump version for worker libs
---
 ...icrosoft.Azure.Functions.Worker.Extensions.Kusto.csproj | 4 ++--
 java-library/pom.xml                                       | 6 +++---
 .../azure/functions/kusto/annotation/KustoOutput.java      | 7 +++++++
 test/IntegrationTests/KustoBindingE2EIntegrationTests.cs   | 3 +--
 4 files changed, 13 insertions(+), 7 deletions(-)

diff --git a/Worker.Extensions.Kusto/Microsoft.Azure.Functions.Worker.Extensions.Kusto.csproj b/Worker.Extensions.Kusto/Microsoft.Azure.Functions.Worker.Extensions.Kusto.csproj
index 842ea45..1f04c84 100644
--- a/Worker.Extensions.Kusto/Microsoft.Azure.Functions.Worker.Extensions.Kusto.csproj
+++ b/Worker.Extensions.Kusto/Microsoft.Azure.Functions.Worker.Extensions.Kusto.csproj
@@ -5,8 +5,8 @@
 		<Description>Kusto extensions for .NET isolated Azure Functions</Description>
 		<Product>Kusto Binding Worker (.NET isolated Azure Functions)</Product>
 		<!-- Default Version for dev -->
-		<Version>1.0.10-Preview</Version>
-		<SupportedVersion>1.0.10-Preview</SupportedVersion>
+		<Version>1.0.11-Preview</Version>
+		<SupportedVersion>1.0.11-Preview</SupportedVersion>
 		<PackageId>Microsoft.Azure.Functions.Worker.Extensions.Kusto</PackageId>
 		<PackageTags>Microsoft Azure WebJobs;AzureFunctions Isolated Dotnet;Isolated Kusto Azure;Kusto Worker</PackageTags>
 		<GenerateAssemblyInfo>true</GenerateAssemblyInfo>
diff --git a/java-library/pom.xml b/java-library/pom.xml
index a681521..5e0f3e2 100644
--- a/java-library/pom.xml
+++ b/java-library/pom.xml
@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.microsoft.azure.functions</groupId>
   <artifactId>azure-functions-java-library-kusto</artifactId>
-  <version>1.0.9-Preview</version>
+  <version>1.0.11-Preview</version>
   <packaging>jar</packaging>
   <name>Microsoft Azure Functions Java Kusto Types</name>
   <description>This package contains all Java annotations to interact with Microsoft Azure Functions runtime for Kusto (ADX) Bindings.</description>
@@ -34,9 +34,9 @@
     <maven.compiler.source>1.8</maven.compiler.source>
     <maven.compiler.target>1.8</maven.compiler.target>
     <azure.functions.maven.plugin.version>1.22.0</azure.functions.maven.plugin.version>
-    <azure.functions.java.library.version>3.0.0</azure.functions.java.library.version>
+    <azure.functions.java.library.version>3.1.0</azure.functions.java.library.version>
     <formatter.version>2.21.0</formatter.version>
-    <junit.version>5.9.2</junit.version>
+    <junit.version>5.11.0</junit.version>
     <maven.compiler.plugin.version>3.8.1</maven.compiler.plugin.version>
     <maven.resources.plugin.version>3.3.0</maven.resources.plugin.version>
     <maven.dependency.plugin.version>3.3.0</maven.dependency.plugin.version>
diff --git a/java-library/src/main/java/com/microsoft/azure/functions/kusto/annotation/KustoOutput.java b/java-library/src/main/java/com/microsoft/azure/functions/kusto/annotation/KustoOutput.java
index 7309c56..decd97c 100644
--- a/java-library/src/main/java/com/microsoft/azure/functions/kusto/annotation/KustoOutput.java
+++ b/java-library/src/main/java/com/microsoft/azure/functions/kusto/annotation/KustoOutput.java
@@ -38,4 +38,11 @@
     // An option to set the ManagedServiceIdentity option. If set to "system" will use SystemManagedIdentity
     // else use UserManagedIdentity
     String managedServiceIdentity() default "";
+
+    // Indicates the type of ingestion. If set to "queued" will use queued ingestion. Defaults to managed ingestion
+    String ingestionTyoe() default "managed";
+
+    // Optional attribute pertinent to queued ingestion type. When using queued ingestion, the following values can be specified
+    // This is specified as ``@flushImmediately=false,@pollIntervalSeconds=15,@pollTimeoutMinutes=5`` like other kusto binding properties.
+    String ingestionProperties() default "@flushImmediately=false,@pollIntervalSeconds=15,@pollTimeoutMinutes=5";
 }
diff --git a/test/IntegrationTests/KustoBindingE2EIntegrationTests.cs b/test/IntegrationTests/KustoBindingE2EIntegrationTests.cs
index 8dd76ba..10ba92f 100644
--- a/test/IntegrationTests/KustoBindingE2EIntegrationTests.cs
+++ b/test/IntegrationTests/KustoBindingE2EIntegrationTests.cs
@@ -568,8 +568,7 @@ public static void InputsValidateQueuedIngestion(
                     Assert.Single(keys);
                     Assert.Equal("Text", keys.First().ToString());
                 }
-
-                Assert.Equal(3, showResults.Count); // 2 success 1 fail
+                Assert.True(showResults.Count >= 2, "There should atleast be 2 ingestions in the last 2 minutes");
                 Assert.True(id > 0);
             }