diff --git a/pom.xml b/pom.xml
index 2f8464b..4718fc3 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.microsoft.azure.functions</groupId>
 	<artifactId>azure-functions-java-library</artifactId>
-	<version>1.4.0</version>
+	<version>1.4.1-SNAPSHOT</version>
 	<packaging>jar</packaging>
 	<parent>
 		<groupId>com.microsoft.maven</groupId>
diff --git a/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusQueueTrigger.java b/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusQueueTrigger.java
index af51441..69895fe 100644
--- a/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusQueueTrigger.java
+++ b/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusQueueTrigger.java
@@ -92,4 +92,12 @@
    * @return The value indicating whether the sessions are enabled.
    */
   boolean isSessionsEnabled() default false;
+
+  /**
+   * Cardinality of the trigger input.
+   * Choose 'One' if the input is a single message or 'Many' if the input is an array of messages.
+   * 'ONE' is the default if unspecified
+   * @return An {@link Cardinality} value representing the Cardinality
+   */
+  Cardinality cardinality() default Cardinality.ONE;
 }
diff --git a/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusTopicTrigger.java b/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusTopicTrigger.java
index d4a5dd6..513df79 100644
--- a/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusTopicTrigger.java
+++ b/src/main/java/com/microsoft/azure/functions/annotation/ServiceBusTopicTrigger.java
@@ -101,4 +101,12 @@
    * @return The value indicating whether the sessions are enabled.
    */
   boolean isSessionsEnabled() default false;
+
+  /**
+   * Cardinality of the trigger input.
+   * Choose 'One' if the input is a single message or 'Many' if the input is an array of messages.
+   * 'ONE' is the default if unspecified
+   * @return An {@link Cardinality} value representing the Cardinality
+   */
+  Cardinality cardinality() default Cardinality.ONE;
 }