@@ -13,7 +13,7 @@ public class EventHubTriggerTests {
13
13
*/
14
14
@ FunctionName ("EventHubTriggerAndOutputJSON" )
15
15
public void EventHubTriggerAndOutputJSON (
16
- @ EventHubTrigger (name = "messages" , eventHubName = "test-inputjson-java" , connection = "AzureWebJobsEventHubSender" ) List <String > messages ,
16
+ @ EventHubTrigger (name = "messages" , eventHubName = "test-inputjson-java" , connection = "AzureWebJobsEventHubSender" , cardinality = Cardinality . MANY ) List <String > messages ,
17
17
@ EventHubOutput (name = "output" , eventHubName = "test-outputjson-java" , connection = "AzureWebJobsEventHubSender" ) OutputBinding <String > output ,
18
18
final ExecutionContext context
19
19
) {
@@ -23,7 +23,7 @@ public void EventHubTriggerAndOutputJSON(
23
23
24
24
@ FunctionName ("EventHubTriggerAndOutputString" )
25
25
public void EventHubTriggerAndOutputString (
26
- @ EventHubTrigger (name = "messages" , eventHubName = "test-input-java" , connection = "AzureWebJobsEventHubSender" , dataType = "string" ) String [] messages ,
26
+ @ EventHubTrigger (name = "messages" , eventHubName = "test-input-java" , connection = "AzureWebJobsEventHubSender" , dataType = "string" , cardinality = Cardinality . MANY ) String [] messages ,
27
27
@ EventHubOutput (name = "output" , eventHubName = "test-output-java" , connection = "AzureWebJobsEventHubSender" ) OutputBinding <String > output ,
28
28
final ExecutionContext context
29
29
) {
@@ -33,7 +33,7 @@ public void EventHubTriggerAndOutputString(
33
33
34
34
@ FunctionName ("EventHubTriggerCardinalityOne" )
35
35
public void EventHubTriggerCardinalityOne (
36
- @ EventHubTrigger (name = "message" , eventHubName = "test-inputOne-java" , connection = "AzureWebJobsEventHubSender" , dataType = "string" ) String message ,
36
+ @ EventHubTrigger (name = "message" , eventHubName = "test-inputOne-java" , connection = "AzureWebJobsEventHubSender" , dataType = "string" , cardinality = Cardinality . ONE ) String message ,
37
37
@ EventHubOutput (name = "output" , eventHubName = "test-outputone-java" , connection = "AzureWebJobsEventHubSender" ) OutputBinding <String > output ,
38
38
final ExecutionContext context
39
39
) {
@@ -56,7 +56,7 @@ public void TestEventHubOutputJson(
56
56
57
57
@ FunctionName ("TestEventHubOutput" )
58
58
public void TestEventHubOutput (
59
- @ EventHubTrigger (name = "message" , eventHubName = "test-output-java" , connection = "AzureWebJobsEventHubSender" ) String message ,
59
+ @ EventHubTrigger (name = "message" , eventHubName = "test-output-java" , connection = "AzureWebJobsEventHubSender" , cardinality = Cardinality . ONE ) String message ,
60
60
@ QueueOutput (name = "output" , queueName = "test-eventhuboutput-java" , connection = "AzureWebJobsStorage" ) OutputBinding <String > output ,
61
61
final ExecutionContext context
62
62
) {
@@ -66,7 +66,7 @@ public void TestEventHubOutput(
66
66
67
67
@ FunctionName ("TestEventHubOutputInputOne" )
68
68
public void TestEventHubOutputInputOne (
69
- @ EventHubTrigger (name = "message" , eventHubName = "test-outputone-java" , connection = "AzureWebJobsEventHubSender" ) String message ,
69
+ @ EventHubTrigger (name = "message" , eventHubName = "test-outputone-java" , connection = "AzureWebJobsEventHubSender" , cardinality = Cardinality . ONE ) String message ,
70
70
@ QueueOutput (name = "output" , queueName = "test-eventhuboutputone-java" , connection = "AzureWebJobsStorage" ) OutputBinding <String > output ,
71
71
final ExecutionContext context
72
72
) {
0 commit comments