This demonstrates queue-based multi-worker communication using Cloudflare Queues:
Benefits:
{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484753109
},
{
"tag": "2-queueEnqueued",
"time": 1764484753109
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484753109
},
{
"tag": "2-queueEnqueued",
"time": 1764484753109
}
]
},
"processedAt": 1764484753626,
"processCount": 93,
"message": "Processed \"Process this data\" by ProcessorDo (total: 93)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484753109
},
{
"tag": "2-queueEnqueued",
"time": 1764484753109
},
{
"tag": "3-processingStarted",
"time": 1764484753626
},
{
"tag": "4-processingCompleted",
"time": 1764484753626
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484752609
},
{
"tag": "2-queueEnqueued",
"time": 1764484752609
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484752609
},
{
"tag": "2-queueEnqueued",
"time": 1764484752609
}
]
},
"processedAt": 1764484753626,
"processCount": 90,
"message": "Processed \"Process this data\" by ProcessorDo (total: 90)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484752609
},
{
"tag": "2-queueEnqueued",
"time": 1764484752609
},
{
"tag": "3-processingStarted",
"time": 1764484753626
},
{
"tag": "4-processingCompleted",
"time": 1764484753626
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484752017
},
{
"tag": "2-queueEnqueued",
"time": 1764484752017
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484752017
},
{
"tag": "2-queueEnqueued",
"time": 1764484752017
}
]
},
"processedAt": 1764484753626,
"processCount": 88,
"message": "Processed \"Process this data\" by ProcessorDo (total: 88)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484752017
},
{
"tag": "2-queueEnqueued",
"time": 1764484752017
},
{
"tag": "3-processingStarted",
"time": 1764484753626
},
{
"tag": "4-processingCompleted",
"time": 1764484753626
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484751422
},
{
"tag": "2-queueEnqueued",
"time": 1764484751422
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484751422
},
{
"tag": "2-queueEnqueued",
"time": 1764484751422
}
]
},
"processedAt": 1764484753626,
"processCount": 92,
"message": "Processed \"Process this data\" by ProcessorDo (total: 92)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484751422
},
{
"tag": "2-queueEnqueued",
"time": 1764484751422
},
{
"tag": "3-processingStarted",
"time": 1764484753626
},
{
"tag": "4-processingCompleted",
"time": 1764484753626
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484750884
},
{
"tag": "2-queueEnqueued",
"time": 1764484750884
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484750884
},
{
"tag": "2-queueEnqueued",
"time": 1764484750884
}
]
},
"processedAt": 1764484753626,
"processCount": 91,
"message": "Processed \"Process this data\" by ProcessorDo (total: 91)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484750884
},
{
"tag": "2-queueEnqueued",
"time": 1764484750884
},
{
"tag": "3-processingStarted",
"time": 1764484753626
},
{
"tag": "4-processingCompleted",
"time": 1764484753626
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484750307
},
{
"tag": "2-queueEnqueued",
"time": 1764484750307
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484750307
},
{
"tag": "2-queueEnqueued",
"time": 1764484750307
}
]
},
"processedAt": 1764484753626,
"processCount": 87,
"message": "Processed \"Process this data\" by ProcessorDo (total: 87)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484750307
},
{
"tag": "2-queueEnqueued",
"time": 1764484750307
},
{
"tag": "3-processingStarted",
"time": 1764484753626
},
{
"tag": "4-processingCompleted",
"time": 1764484753626
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484749378
},
{
"tag": "2-queueEnqueued",
"time": 1764484749378
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484749378
},
{
"tag": "2-queueEnqueued",
"time": 1764484749378
}
]
},
"processedAt": 1764484753626,
"processCount": 89,
"message": "Processed \"Process this data\" by ProcessorDo (total: 89)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764484749378
},
{
"tag": "2-queueEnqueued",
"time": 1764484749378
},
{
"tag": "3-processingStarted",
"time": 1764484753626
},
{
"tag": "4-processingCompleted",
"time": 1764484753626
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764483909556
},
{
"tag": "2-queueEnqueued",
"time": 1764483909556
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764483909556
},
{
"tag": "2-queueEnqueued",
"time": 1764483909556
}
]
},
"processedAt": 1764483911583,
"processCount": 86,
"message": "Processed \"Process this data\" by ProcessorDo (total: 86)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1764483909556
},
{
"tag": "2-queueEnqueued",
"time": 1764483909556
},
{
"tag": "3-processingStarted",
"time": 1764483911583
},
{
"tag": "4-processingCompleted",
"time": 1764483911583
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1762204313697
},
{
"tag": "2-queueEnqueued",
"time": 1762204313697
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1762204313697
},
{
"tag": "2-queueEnqueued",
"time": 1762204313697
}
]
},
"processedAt": 1762204315958,
"processCount": 85,
"message": "Processed \"Process this data\" by ProcessorDo (total: 85)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1762204313697
},
{
"tag": "2-queueEnqueued",
"time": 1762204313697
},
{
"tag": "3-processingStarted",
"time": 1762204315958
},
{
"tag": "4-processingCompleted",
"time": 1762204315958
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
}
]
},
"processedAt": 1761224239115,
"processCount": 81,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 81)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
},
{
"tag": "3-processingStarted",
"time": 1761224239115
},
{
"tag": "4-processingCompleted",
"time": 1761224239115
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
}
]
},
"processedAt": 1761224239116,
"processCount": 84,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 84)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
},
{
"tag": "3-processingStarted",
"time": 1761224239116
},
{
"tag": "4-processingCompleted",
"time": 1761224239116
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
}
]
},
"processedAt": 1761224239114,
"processCount": 80,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 80)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
},
{
"tag": "3-processingStarted",
"time": 1761224239114
},
{
"tag": "4-processingCompleted",
"time": 1761224239114
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
}
]
},
"processedAt": 1761224239116,
"processCount": 82,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 82)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
},
{
"tag": "3-processingStarted",
"time": 1761224239116
},
{
"tag": "4-processingCompleted",
"time": 1761224239116
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
}
]
},
"processedAt": 1761224239116,
"processCount": 83,
"message": "Processed \"Process this data\" by ProcessorDo (total: 83)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224237933
},
{
"tag": "2-queueEnqueued",
"time": 1761224237933
},
{
"tag": "3-processingStarted",
"time": 1761224239116
},
{
"tag": "4-processingCompleted",
"time": 1761224239116
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
}
]
},
"processedAt": 1761224238644,
"processCount": 77,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 77)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
},
{
"tag": "3-processingStarted",
"time": 1761224238644
},
{
"tag": "4-processingCompleted",
"time": 1761224238644
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
}
]
},
"processedAt": 1761224238621,
"processCount": 74,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 74)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
},
{
"tag": "3-processingStarted",
"time": 1761224238621
},
{
"tag": "4-processingCompleted",
"time": 1761224238621
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
}
]
},
"processedAt": 1761224238644,
"processCount": 78,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 78)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
},
{
"tag": "3-processingStarted",
"time": 1761224238644
},
{
"tag": "4-processingCompleted",
"time": 1761224238644
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
}
]
},
"processedAt": 1761224238644,
"processCount": 79,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 79)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
},
{
"tag": "3-processingStarted",
"time": 1761224238644
},
{
"tag": "4-processingCompleted",
"time": 1761224238644
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
}
]
},
"processedAt": 1761224238644,
"processCount": 76,
"message": "Processed \"Process this data\" by ProcessorDo (total: 76)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235780
},
{
"tag": "2-queueEnqueued",
"time": 1761224235780
},
{
"tag": "3-processingStarted",
"time": 1761224238644
},
{
"tag": "4-processingCompleted",
"time": 1761224238644
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
}
]
},
"processedAt": 1761224238123,
"processCount": 65,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 65)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
},
{
"tag": "3-processingStarted",
"time": 1761224238123
},
{
"tag": "4-processingCompleted",
"time": 1761224238123
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
}
]
},
"processedAt": 1761224238618,
"processCount": 70,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 70)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
},
{
"tag": "3-processingStarted",
"time": 1761224238618
},
{
"tag": "4-processingCompleted",
"time": 1761224238618
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
}
]
},
"processedAt": 1761224238124,
"processCount": 69,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 69)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
},
{
"tag": "3-processingStarted",
"time": 1761224238124
},
{
"tag": "4-processingCompleted",
"time": 1761224238124
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
}
]
},
"processedAt": 1761224238618,
"processCount": 72,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 72)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
},
{
"tag": "3-processingStarted",
"time": 1761224238618
},
{
"tag": "4-processingCompleted",
"time": 1761224238618
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
}
]
},
"processedAt": 1761224238618,
"processCount": 71,
"message": "Processed \"Process this data\" by ProcessorDo (total: 71)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235635
},
{
"tag": "2-queueEnqueued",
"time": 1761224235635
},
{
"tag": "3-processingStarted",
"time": 1761224238618
},
{
"tag": "4-processingCompleted",
"time": 1761224238618
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
}
]
},
"processedAt": 1761224238099,
"processCount": 61,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 61)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
},
{
"tag": "3-processingStarted",
"time": 1761224238099
},
{
"tag": "4-processingCompleted",
"time": 1761224238099
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
}
]
},
"processedAt": 1761224238618,
"processCount": 73,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 73)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
},
{
"tag": "3-processingStarted",
"time": 1761224238618
},
{
"tag": "4-processingCompleted",
"time": 1761224238618
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
}
]
},
"processedAt": 1761224238098,
"processCount": 60,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 60)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
},
{
"tag": "3-processingStarted",
"time": 1761224238098
},
{
"tag": "4-processingCompleted",
"time": 1761224238098
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
}
]
},
"processedAt": 1761224238628,
"processCount": 75,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 75)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
},
{
"tag": "3-processingStarted",
"time": 1761224238628
},
{
"tag": "4-processingCompleted",
"time": 1761224238628
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
}
]
},
"processedAt": 1761224238124,
"processCount": 67,
"message": "Processed \"Process this data\" by ProcessorDo (total: 67)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235456
},
{
"tag": "2-queueEnqueued",
"time": 1761224235456
},
{
"tag": "3-processingStarted",
"time": 1761224238124
},
{
"tag": "4-processingCompleted",
"time": 1761224238124
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
}
]
},
"processedAt": 1761224238124,
"processCount": 66,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 66)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
},
{
"tag": "3-processingStarted",
"time": 1761224238124
},
{
"tag": "4-processingCompleted",
"time": 1761224238124
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
}
]
},
"processedAt": 1761224237604,
"processCount": 57,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 57)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
},
{
"tag": "3-processingStarted",
"time": 1761224237604
},
{
"tag": "4-processingCompleted",
"time": 1761224237604
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
}
]
},
"processedAt": 1761224238099,
"processCount": 62,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 62)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
},
{
"tag": "3-processingStarted",
"time": 1761224238099
},
{
"tag": "4-processingCompleted",
"time": 1761224238099
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
}
]
},
"processedAt": 1761224238124,
"processCount": 68,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 68)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
},
{
"tag": "3-processingStarted",
"time": 1761224238124
},
{
"tag": "4-processingCompleted",
"time": 1761224238124
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
}
]
},
"processedAt": 1761224238099,
"processCount": 63,
"message": "Processed \"Process this data\" by ProcessorDo (total: 63)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235282
},
{
"tag": "2-queueEnqueued",
"time": 1761224235282
},
{
"tag": "3-processingStarted",
"time": 1761224238099
},
{
"tag": "4-processingCompleted",
"time": 1761224238099
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
}
]
},
"processedAt": 1761224237606,
"processCount": 59,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 59)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
},
{
"tag": "3-processingStarted",
"time": 1761224237606
},
{
"tag": "4-processingCompleted",
"time": 1761224237606
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
}
]
},
"processedAt": 1761224237606,
"processCount": 58,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 58)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
},
{
"tag": "3-processingStarted",
"time": 1761224237606
},
{
"tag": "4-processingCompleted",
"time": 1761224237606
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
}
]
},
"processedAt": 1761224237580,
"processCount": 50,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 50)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
},
{
"tag": "3-processingStarted",
"time": 1761224237580
},
{
"tag": "4-processingCompleted",
"time": 1761224237580
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
}
]
},
"processedAt": 1761224237603,
"processCount": 56,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 56)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
},
{
"tag": "3-processingStarted",
"time": 1761224237603
},
{
"tag": "4-processingCompleted",
"time": 1761224237603
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
}
]
},
"processedAt": 1761224238099,
"processCount": 64,
"message": "Processed \"Process this data\" by ProcessorDo (total: 64)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224235152
},
{
"tag": "2-queueEnqueued",
"time": 1761224235152
},
{
"tag": "3-processingStarted",
"time": 1761224238099
},
{
"tag": "4-processingCompleted",
"time": 1761224238099
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
}
]
},
"processedAt": 1761224237583,
"processCount": 54,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 54)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
},
{
"tag": "3-processingStarted",
"time": 1761224237583
},
{
"tag": "4-processingCompleted",
"time": 1761224237583
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
}
]
},
"processedAt": 1761224236989,
"processCount": 48,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 48)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
},
{
"tag": "3-processingStarted",
"time": 1761224236989
},
{
"tag": "4-processingCompleted",
"time": 1761224236989
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
}
]
},
"processedAt": 1761224237583,
"processCount": 53,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 53)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
},
{
"tag": "3-processingStarted",
"time": 1761224237583
},
{
"tag": "4-processingCompleted",
"time": 1761224237583
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
}
]
},
"processedAt": 1761224237591,
"processCount": 55,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 55)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
},
{
"tag": "3-processingStarted",
"time": 1761224237591
},
{
"tag": "4-processingCompleted",
"time": 1761224237591
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
}
]
},
"processedAt": 1761224236989,
"processCount": 47,
"message": "Processed \"Process this data\" by ProcessorDo (total: 47)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234973
},
{
"tag": "2-queueEnqueued",
"time": 1761224234973
},
{
"tag": "3-processingStarted",
"time": 1761224236989
},
{
"tag": "4-processingCompleted",
"time": 1761224236989
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
}
]
},
"processedAt": 1761224236988,
"processCount": 46,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 46)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
},
{
"tag": "3-processingStarted",
"time": 1761224236988
},
{
"tag": "4-processingCompleted",
"time": 1761224236988
}
]
}{
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
}
]
}{
"processed": true,
"input": {
"message": "Process this data 4",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
}
]
},
"processedAt": 1761224236963,
"processCount": 42,
"message": "Processed \"Process this data 4\" by ProcessorDo (total: 42)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
},
{
"tag": "3-processingStarted",
"time": 1761224236963
},
{
"tag": "4-processingCompleted",
"time": 1761224236963
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
}
]
},
"processedAt": 1761224237582,
"processCount": 52,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 52)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
},
{
"tag": "3-processingStarted",
"time": 1761224237582
},
{
"tag": "4-processingCompleted",
"time": 1761224237582
}
]
}{
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
}
]
}{
"processed": true,
"input": {
"message": "Process this data 3",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
}
]
},
"processedAt": 1761224237581,
"processCount": 51,
"message": "Processed \"Process this data 3\" by ProcessorDo (total: 51)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
},
{
"tag": "3-processingStarted",
"time": 1761224237581
},
{
"tag": "4-processingCompleted",
"time": 1761224237581
}
]
}{
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
}
]
}{
"processed": true,
"input": {
"message": "Process this data",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
}
]
},
"processedAt": 1761224236989,
"processCount": 49,
"message": "Processed \"Process this data\" by ProcessorDo (total: 49)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234809
},
{
"tag": "2-queueEnqueued",
"time": 1761224234809
},
{
"tag": "3-processingStarted",
"time": 1761224236989
},
{
"tag": "4-processingCompleted",
"time": 1761224236989
}
]
}{
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234489
},
{
"tag": "2-queueEnqueued",
"time": 1761224234489
}
]
}{
"processed": true,
"input": {
"message": "Process this data 5",
"delay": 0,
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234489
},
{
"tag": "2-queueEnqueued",
"time": 1761224234489
}
]
},
"processedAt": 1761224236965,
"processCount": 44,
"message": "Processed \"Process this data 5\" by ProcessorDo (total: 44)",
"timestamps": [
{
"tag": "1-serverReceived",
"time": 1761224234489
},
{
"tag": "2-queueEnqueued",
"time": 1761224234489
},
{
"tag": "3-processingStarted",
"time": 1761224236965
},
{
"tag": "4-processingCompleted",
"time": 1761224236965
}
]
}