Add queue binding samples (#33).
This commit is contained in:
Родитель
256cb7e62c
Коммит
9e6ceaeabb
|
@ -20,6 +20,18 @@ import java.lang.annotation.Target;
|
||||||
* <li>Any POJO type</li>
|
* <li>Any POJO type</li>
|
||||||
* </ul>
|
* </ul>
|
||||||
*
|
*
|
||||||
|
* <p>The following example shows a Java function that creates a queue message for each HTTP request received.</p>
|
||||||
|
*
|
||||||
|
* <pre>{@literal @}FunctionName("httpToQueue")
|
||||||
|
*{@literal @}QueueOutput(name = "item", queueName = "myqueue-items", connection = "AzureWebJobsStorage")
|
||||||
|
* public String pushToQueue(
|
||||||
|
* {@literal @}HttpTrigger(name = "request", methods = {HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS)
|
||||||
|
* final String message,
|
||||||
|
* {@literal @}HttpOutput(name = "response") final OutputBinding<String> result
|
||||||
|
* ) {
|
||||||
|
* result.setValue(message + " has been added.");
|
||||||
|
* return message;
|
||||||
|
* }</pre>
|
||||||
*
|
*
|
||||||
* @since 1.0.0
|
* @since 1.0.0
|
||||||
*/
|
*/
|
||||||
|
|
|
@ -21,16 +21,15 @@ import java.lang.annotation.Target;
|
||||||
* <li>Any POJO type</li>
|
* <li>Any POJO type</li>
|
||||||
* </ul>
|
* </ul>
|
||||||
*
|
*
|
||||||
* <p>The following example shows a storage queue trigger which logs the message:</p>
|
* <p>The following example shows a Java function that polls the "myqueue-items" queue and writes a log each time a
|
||||||
|
* queue item is processed.</p>
|
||||||
*
|
*
|
||||||
* <pre>{@literal @}FunctionName("queueprocessor")
|
* <pre>{@literal @}FunctionName("queueMonitor")
|
||||||
* public void run(
|
* public void logQueueItem(
|
||||||
* {@literal @}QueueTrigger(name = "msg",
|
* {@literal @}QueueTrigger(name = "msg", queueName = "myqueue-items", connection = "AzureWebJobsStorage") String message,
|
||||||
* queueName = "myqueuename",
|
|
||||||
* connection = "myconnvarname") String message,
|
|
||||||
* final ExecutionContext context
|
* final ExecutionContext context
|
||||||
* ) {
|
* ) {
|
||||||
* context.getLogger().info(message);
|
* context.getLogger().info("Queue message processed: " + message);
|
||||||
* }</pre>
|
* }</pre>
|
||||||
*
|
*
|
||||||
* @since 1.0.0
|
* @since 1.0.0
|
||||||
|
|
Загрузка…
Ссылка в новой задаче