com.pega.pegarules.pub.context

Interface DedicatedQueueProcessor

public interface DedicatedQueueProcessor

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	VERSION

Method Summary

Modifier and Type	Method and Description
void	deferredUpdate(java.lang.String itemId, ClipboardPage message, java.lang.String dateTimeDelayProperty) Defer updates the delayed queue item in the delayed table
void	dequeue(java.lang.String itemId) Dequeues the item from delayed table
void	dequeueDeferred(java.lang.String itemId) Defer dequeue the item from delayed table
java.lang.String	enqueue(ClipboardPage message, EnqueueOperationConfig config) With the given message and config, the message is enqueued to the delayed table
ClipboardPage	getDelayedMessageForUpdate(java.lang.String itemID) For the given itemID, Updates the pyItemStatus to 'Now-Updating' in delayed table and returns the message page for update
boolean	repair(java.lang.String itemId) Repairs an item which is in broken and requeues it without creating a new itemID.
void	updateQueueItem(java.lang.String itemId, ClipboardPage message, java.lang.String dateTimeDelayProperty) Updates the delayed queue item in the delayed table

Field Detail

VERSION

static final java.lang.String VERSION

Method Detail

enqueue

java.lang.String enqueue(ClipboardPage message,
                         EnqueueOperationConfig config)

With the given message and config, the message is enqueued to the delayed table

Parameters:

message - To be enqueued

config - EnqueueOperationConfig

Returns:

String itemID for the enqueued message, which is then used while dequeue or update of the message

dequeue

void dequeue(java.lang.String itemId)

Dequeues the item from delayed table

Parameters:

itemId - of message

updateQueueItem

void updateQueueItem(java.lang.String itemId,
                     ClipboardPage message,
                     java.lang.String dateTimeDelayProperty)
              throws DatabaseException

Updates the delayed queue item in the delayed table

Parameters:

itemId - of message

message - is the new message to be updated

dateTimeDelayProperty - is the new dateTimeDelayProperty to be updated

Throws:

DatabaseException

deferredUpdate

void deferredUpdate(java.lang.String itemId,
                    ClipboardPage message,
                    java.lang.String dateTimeDelayProperty)
             throws DatabaseException

Defer updates the delayed queue item in the delayed table

Parameters:

itemId - of message

message - is the new message to be updated

dateTimeDelayProperty - is the new dateTimeDelayProperty to be updated

Throws:

DatabaseException

getDelayedMessageForUpdate

ClipboardPage getDelayedMessageForUpdate(java.lang.String itemID)
                                  throws DatabaseException

For the given itemID, Updates the pyItemStatus to 'Now-Updating' in delayed table and returns the message page for update

Parameters:

itemID - of message

Returns:

the messagepage for update

Throws:

DatabaseException

dequeueDeferred

void dequeueDeferred(java.lang.String itemId)

Defer dequeue the item from delayed table

Parameters:

itemId - of message

repair

boolean repair(java.lang.String itemId)

Repairs an item which is in broken and requeues it without creating a new itemID. This api retains the existing accessGroup in item. This api also clears error details before requeuing.

Parameters:

itemId - Item ID to repair