@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");
        }
    }
@ 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.