Skip to content
This repository was archived by the owner on Mar 2, 2022. It is now read-only.

Commit 68e679a

Browse files
committed
add queue trigger.
1 parent 1dafc07 commit 68e679a

File tree

1 file changed

+20
-0
lines changed

1 file changed

+20
-0
lines changed
Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
package com.function.hosomi;
2+
3+
import com.microsoft.azure.functions.annotation.*;
4+
import com.microsoft.azure.functions.*;
5+
6+
/**
7+
* Azure Functions with Azure Storage Queue trigger.
8+
*/
9+
public class QueueTriggerJava {
10+
/**
11+
* This function will be invoked when a new message is received at the specified path. The message contents are provided as input to this function.
12+
*/
13+
@FunctionName("QueueTriggerJava")
14+
public void run(
15+
@QueueTrigger(name = "message", queueName = "queue-items", connection = "AzureWebJobsStorage") String message,
16+
final ExecutionContext context
17+
) {
18+
context.getLogger().info("Java Queue trigger function processed a message: " + message);
19+
}
20+
}

0 commit comments

Comments
 (0)