public void update()

in function-apps/Append-Transaction/src/main/java/org/inventory/hub/AppendTransaction.java [26:42]


    public void update(
        @EventHubTrigger(name = "data", eventHubName = "%TRANSACTIONS_EVENT_HUB_NAME%",
            connection = "TRANSACTIONS_EVENT_HUB_CONNECTION_STRING",
            cardinality = Cardinality.ONE,
            consumerGroup = "%TRANSACTIONS_EVENT_HUB_CONSUMER_GROUP_NAME%") TransactionEvent data,
        @CosmosDBOutput(name = "document", databaseName = "%TRANSACTIONS_COSMOSDB_DBNAME%",
        collectionName = "%TRANSACTIONS_COSMOSDB_COLLECTION_NAME%",
        connectionStringSetting = "TRANSACTIONS_COSMOSDB_CONNECTION_STRING",
        createIfNotExists = true) OutputBinding<TransactionDocument> document,
        final ExecutionContext context) {

        context.getLogger().info("Java Event Hub transaction trigger from "
            + System.getenv("APPEND_TRANSACTION_FUNCTION_APP_NAME")
            + "(" + System.getenv("APPEND_TRANSACTION_FUNCTION_APP_ID")
            + ") processed a request: " + data.getValue());
        handleOutput(data, document, context);
    }