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);
}