1# Java — Azure Functions Triggers & Bindings
2 
3> **Model**: Java annotation-based model. Uses `@FunctionName` and trigger/binding annotations.
4> Import: `com.microsoft.azure.functions.*` and `com.microsoft.azure.functions.annotation.*`
5 
6## HTTP Trigger
7 
8```java
9@FunctionName("HttpFunction")
10public HttpResponseMessage run(
11    @HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST},
12                 authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<Optional<String>> request,
13    final ExecutionContext context) {
14    String name = request.getQueryParameters().get("name");
15    return request.createResponseBuilder(HttpStatus.OK).body("Hello, " + name).build();
16}
17```
18 
19## Blob Storage
20 
21```java
22// Trigger
23@FunctionName("BlobTrigger")
24public void run(
25    @BlobTrigger(name = "blob", path = "samples-workitems/{name}",
26                 connection = "AzureWebJobsStorage") byte[] content,
27    @BindingName("name") String name,
28    final ExecutionContext context) {
29    context.getLogger().info("Blob: " + name + ", Size: " + content.length);
30}
31 
32// Input
33@BlobInput(name = "inputBlob", path = "input/{name}", connection = "AzureWebJobsStorage")
34 
35// Output
36@BlobOutput(name = "outputBlob", path = "output/{name}-out", connection = "AzureWebJobsStorage")
37```
38 
39## Queue Storage
40 
41```java
42// Trigger
43@FunctionName("QueueTrigger")
44public void run(
45    @QueueTrigger(name = "message", queueName = "myqueue-items",
46                  connection = "AzureWebJobsStorage") String message,
47    final ExecutionContext context) {
48    context.getLogger().info("Queue message: " + message);
49}
50 
51// Output
52@QueueOutput(name = "output", queueName = "outqueue", connection = "AzureWebJobsStorage")
53```
54 
55## Timer
56 
57```java
58@FunctionName("TimerFunction")
59public void run(
60    @TimerTrigger(name = "timer", schedule = "0 */5 * * * *") String timerInfo,
61    final ExecutionContext context) {
62    context.getLogger().info("Timer triggered");
63}
64```
65 
66## Event Grid
67 
68```java
69// Trigger
70@FunctionName("EventGridTrigger")
71public void run(
72    @EventGridTrigger(name = "event") EventGridEvent event,
73    final ExecutionContext context) {
74    context.getLogger().info("Event: " + event.subject());
75}
76 
77// Output
78@EventGridOutput(name = "output", topicEndpointUri = "MyTopicUri",
79                 topicKeySetting = "MyTopicKey")
80```
81 
82## Cosmos DB
83 
84```java
85// Trigger (Change Feed)
86@FunctionName("CosmosDBTrigger")
87public void run(
88    @CosmosDBTrigger(name = "documents", databaseName = "mydb",
89                     containerName = "mycontainer", connection = "CosmosDBConnection",
90                     createLeaseContainerIfNotExists = true) String[] documents,
91    final ExecutionContext context) {
92    for (String doc : documents) context.getLogger().info("Doc: " + doc);
93}
94 
95// Input
96@CosmosDBInput(name = "doc", databaseName = "mydb", containerName = "mycontainer",
97               connection = "CosmosDBConnection", id = "{id}", partitionKey = "{pk}")
98 
99// Output
100@CosmosDBOutput(name = "newdoc", databaseName = "mydb", containerName = "mycontainer",
101                connection = "CosmosDBConnection")
102```
103 
104## Service Bus
105 
106```java
107// Queue Trigger
108@FunctionName("SBQueueTrigger")
109public void run(
110    @ServiceBusQueueTrigger(name = "message", queueName = "myqueue",
111                            connection = "ServiceBusConnection") String message,
112    final ExecutionContext context) {
113    context.getLogger().info("Message: " + message);
114}
115 
116// Topic Trigger
117@FunctionName("SBTopicTrigger")
118public void run(
119    @ServiceBusTopicTrigger(name = "message", topicName = "mytopic",
120                            subscriptionName = "mysubscription",
121                            connection = "ServiceBusConnection") String message,
122    final ExecutionContext context) {
123    context.getLogger().info("Topic: " + message);
124}
125 
126// Output
127@ServiceBusQueueOutput(name = "output", queueName = "outqueue",
128                       connection = "ServiceBusConnection")
129```
130 
131## Event Hubs
132 
133```java
134// Trigger
135@FunctionName("EventHubTrigger")
136public void run(
137    @EventHubTrigger(name = "event", eventHubName = "myeventhub",
138                     connection = "EventHubConnection", cardinality = Cardinality.MANY) List<String> events,
139    final ExecutionContext context) {
140    events.forEach(e -> context.getLogger().info("Event: " + e));
141}
142 
143// Output
144@EventHubOutput(name = "output", eventHubName = "outeventhub",
145                connection = "EventHubConnection")
146```
147 
148## Table Storage
149 
150```java
151// Input
152@TableInput(name = "entity", tableName = "mytable", partitionKey = "{pk}",
153            rowKey = "{rk}", connection = "AzureWebJobsStorage")
154 
155// Output
156@TableOutput(name = "output", tableName = "mytable", connection = "AzureWebJobsStorage")
157```
158 
159## SQL
160 
161```java
162// Trigger
163@FunctionName("SqlTrigger")
164public void run(
165    @SqlTrigger(name = "changes", tableName = "dbo.MyTable",
166                connectionStringSetting = "SqlConnection") SqlChange[] changes,
167    final ExecutionContext context) {
168    for (SqlChange change : changes) context.getLogger().info("Change: " + change);
169}
170 
171// Input
172@SqlInput(name = "items", commandText = "SELECT * FROM dbo.MyTable WHERE Id = @Id",
173          commandType = "Text", parameters = "@Id={id}",
174          connectionStringSetting = "SqlConnection")
175 
176// Output
177@SqlOutput(name = "output", commandText = "dbo.MyTable",
178           connectionStringSetting = "SqlConnection")
179```
180 
181## SignalR
182 
183```java
184@SignalROutput(name = "signalr", hubName = "myhub",
185               connectionStringSetting = "AzureSignalRConnectionString")
186```
187 
188## SendGrid
189 
190```java
191@SendGridOutput(name = "mail", apiKey = "SendGridApiKey",
192                from = "[email protected]", to = "{email}")
193```
194 
195## Multiple Outputs
196 
197Java uses `OutputBinding<T>` for additional outputs:
198 
199```java
200@FunctionName("MultiOutput")
201public HttpResponseMessage run(
202    @HttpTrigger(name = "req", methods = {HttpMethod.POST},
203                 authLevel = AuthorizationLevel.ANONYMOUS) HttpRequestMessage<String> request,
204    @QueueOutput(name = "output", queueName = "outqueue",
205                 connection = "AzureWebJobsStorage") OutputBinding<String> queueOutput,
206    final ExecutionContext context) {
207    queueOutput.setValue("new item");
208    return request.createResponseBuilder(HttpStatus.OK).body("Processed").build();
209}
210```
211 
212> **Note**: Java uses `function.json` generated at build time by the Maven plugin — you don't write them manually.
213 
214> Full reference: [Azure Functions Java developer guide](https://learn.microsoft.com/en-us/azure/azure-functions/functions-reference-java)
215