@@ -38,9 +38,9 @@ The following code is an example function that starts a new orchestration instan
38
38
# [ C#] ( #tab/csharp )
39
39
40
40
``` csharp
41
- [FunctionName (" HelloWorldManualStart " )]
41
+ [FunctionName (" HelloWorldQueueTrigger " )]
42
42
public static async Task Run (
43
- [ManualTrigger ] string input ,
43
+ [QueueTrigger ( " start-queue " ) ] string input ,
44
44
[DurableClient ] IDurableOrchestrationClient starter ,
45
45
ILogger log )
46
46
{
@@ -157,7 +157,7 @@ This method returns `null` (.NET) or `undefined` (JavaScript) if the instance do
157
157
[FunctionName (" GetStatus" )]
158
158
public static async Task Run (
159
159
[DurableClient ] IDurableOrchestrationClient client ,
160
- [ManualTrigger ] string instanceId )
160
+ [QueueTrigger ( " check-status-queue " ) ] string instanceId )
161
161
{
162
162
DurableOrchestrationStatus status = await client .GetStatusAsync (instanceId );
163
163
// do something based on the current status.
@@ -359,7 +359,7 @@ You can use the `TerminateAsync` (.NET) or the `terminate` (JavaScript) method o
359
359
[FunctionName (" TerminateInstance" )]
360
360
public static Task Run (
361
361
[DurableClient ] IDurableOrchestrationClient client ,
362
- [ManualTrigger ] string instanceId )
362
+ [QueueTrigger ( " terminate-queue " ) ] string instanceId )
363
363
{
364
364
string reason = " It was time to be done." ;
365
365
return client .TerminateAsync (instanceId , reason );
@@ -424,7 +424,7 @@ The parameters to `RaiseEventAsync` (.NET) and `raiseEvent` (JavaScript) are as
424
424
[FunctionName (" RaiseEvent" )]
425
425
public static Task Run (
426
426
[DurableClient ] IDurableOrchestrationClient client ,
427
- [ManualTrigger ] string instanceId )
427
+ [QueueTrigger ( " event-queue " ) ] string instanceId )
428
428
{
429
429
int [] eventData = new int [] { 1 , 2 , 3 };
430
430
return client .RaiseEventAsync (instanceId , " MyEvent" , eventData );
@@ -618,7 +618,7 @@ For example, let's say you have a workflow involving a series of [human approval
618
618
[FunctionName (" RewindInstance" )]
619
619
public static Task Run (
620
620
[DurableClient ] IDurableOrchestrationClient client ,
621
- [ManualTrigger ] string instanceId )
621
+ [QueueTrigger ( " rewind-queue " ) ] string instanceId )
622
622
{
623
623
string reason = " Orchestrator failed and needs to be revived." ;
624
624
return client .RewindAsync (instanceId , reason );
@@ -670,7 +670,7 @@ This method has two overloads. The first overload purges history by the ID of th
670
670
[FunctionName (" PurgeInstanceHistory" )]
671
671
public static Task Run (
672
672
[DurableClient ] IDurableOrchestrationClient client ,
673
- [ManualTrigger ] string instanceId )
673
+ [QueueTrigger ( " purge-queue " ) ] string instanceId )
674
674
{
675
675
return client .PurgeInstanceHistoryAsync (instanceId );
676
676
}
0 commit comments