@ FunctionName ( "EventHubTriggerJava" ) public void run ( @ EventHubTrigger ( name = "message" , eventHubName = "trigger" , connection = "CIEventHubConnection" , consumerGroup = "$Default" ) String message , @ EventHubOutput ( name = "result" , eventHubName = "output" , connection = "CIEventHubConnection" ) OutputBinding < String > result , final ExecutionContext context ) { if ( message . contains ( "CIInput" ) ) { result . setValue ( "CITest" ) ; } }
This function will be invoked when an event is received from Event Hub .