Queue-For-Processing method

Use this method to specify the details of queue processors that run in your application.

Step Page

Optional. Identify the class of the work item or other item that is to be processed. This page is available later as context to the queue processor activity that processes the item, for example:
  • If the queued item refers to a work item, set the step page to the work page (typically pyWorkPage ).
  • If the queued item is an assignment, set the step page to the assignment page (typically NewAssignPage ).
  • If the Step Page value in the step is blank, the primary page of the calling activity is used.

Parameters

This method has the following parameters:

Field name Available field values Description Default value
Type of queue Standard An item is queued to a standard queue processor. You do not need to create a new queue processor. Standard
Dedicated An item is queued to a custom queue processor.
Queue processor Press the Down arrow key to view the list of available queue processors. A name of the queue processor to which items are queued. N/A
Date/time for processing A DateTime property in the class of the step page. This option is available for dedicated queue processors only. A DateTime property by which you specify when a dedicated queue processor resolves the activity. The property represents the time after which an item can be processed. N/A
Activity name Press the Down arrow key to view the list of available activities. Enter parameter values in the appropriate fields. A name of the activity that is resolved by the queue processor. When you enter the name of the activity, the parameters for that activity are displayed. N/A
Lock using Primary page Open a page by using a pzInskey property and lock it. This page is available to Processing activity as pyQueuePage. Primary page
Key defined on property Open a page by using a key defined on a property. This page is available to Processing activity as pyOtherPage. You need to enter a name of the property.
None Open a page without a lock from the database by using the pzInskey property.
Long running queue processor threshold Number of milliseconds greater than 0 A performance alert is generated when the activity runs longer than the threshold value.

For more information, see PEGA0117 alert: Long-running queue processor activity.

 2s
Write now No The message is queued as a part of the next database commit. No
Yes The message is queued immediately and is not a part of any transaction.
Timeout to acquire lock (in minutes) Number of minutes greater than 0 The system attempts to acquire the lock every minute until the specified value is reached. The system increases the retry attempt counter when the time-out value is reached. 30
Number of minutes less than 0 The system attempts to acquire the lock every minute and does not treat retries as failed attempts. The system does not increase the retry attempt counter.
0 The system treats a failed lock try as a failed attempt and increases the retry attempt counter.
Queue current snapshot of page No When a page that has a pzInskey property is queued, the message stores the pzInskey value only. When an item is processed by using the pzInskey property, the corresponding record from the database opens. No
Yes The message that is queued stores the entire page. This is an advanced option that you can use for performance optimization.
Note: This option is available only when locking is set to None.
Alternate access group Press the Down Arrow key to prompt the list of available access groups. Define an alternate access group when you want to process the item in a different context from the access group that is defined in the queue processor. N/A

Results

The system queues the page to the embedded Kafka data instance. This occurs immediately or at the next Commit method run, depending on the Write Now setting. The queue processor picks up this item from the queue and processes the activity configured. A unique ID is generated to represent the ItemID and is available on the parameter page as the parameter, pxItemID.

Broken queue

When a queue processor tries to process an item for the number of times that you specify in the MaxAttempts parameter, and the queue processor is not successful, the item is moved to the broken queue. You can view the list of broken items in Admin Studio, on the Queue Processor landing page. To view the list of the broken items, you must have the pzQueueProcessorObserver privilege. To resubmit or delete items from the broken queue, you must have the pzQueueProcessorAdministrator privilege.