Toggle menu

processDigestQueue()

When a call is made to digestHistories(), the digest is added to a queue. This function processes that queue.

Each call will process the queue for 13 seconds before stopping. 

Scheduled Task
Note that an iCM scheduled task calls this function every 15 seconds, calling it directly shouldn't be necessary. You can inspect the digest queue from the iCM/API Servers page.

Parameters

None.

Returns

An array of objects. Each object in the array holds the details of one digest, matching the response described on digestHistories().

Example

Request

function(params, credentials) {
    let resp = this.callWorkerMethod("history", "processDigestQueue", {});
    return resp;
}

Response

{
    "result": {
        "result": [{
                "totalValueCount": 0,
                "columns": {
                    "test_slow_digests.all_isbn": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "test_slow_digests.distinct_authors": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "test_slow_digests.distinct_authors.author": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "test_slow_digests.all_isbn.isbn": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "test_slow_digests.first_title": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "test_slow_digests.last_location": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    }
                },
                "name": "test_digests",
                "allEventsProcessed": true,
                "totalNewRowsCount": 0
            },
            {
                "totalValueCount": 0,
                "columns": {
                    "rb_cancellations.floor": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "rb_cancellations.bookername": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "rb_cancellations.paid": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "rb_cancellations.paymentmethod": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "rb_cancellations.bookerphone": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "rb_cancellations.cancellationdate": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    },
                    "rb_cancellations.payamount": {
                        "valueCount": 0,
                        "cursorPosition": 54645,
                        "allEventsProcessed": true,
                        "newRowsCount": 0
                    }
                },
                "name": "rb_cancellations",
                "allEventsProcessed": true,
                "totalNewRowsCount": 0
            }
        ]
    },
    "id": "123",
    "jsonrpc": "2.0"
}

Last modified on 3 June 2025