2.0.122 • Published 2 years ago
@tix-factory/queueing v2.0.122
@tix-factory/queueing
TODO
Example
import { HttpClient } from "@tix-factory/http";
import { RemoteQueue, QueueProcessor } from "@tix-factory/queueing";
const httpClient = new HttpClient();
//const queue = new queueing.VirtualQueue();
const queue = new RemoteQueue(httpClient, console, {
queueName: "Example",
countRefreshInterval: 1000
});
const queueProcessor = new QueueProcessor({
numberOfThreads: 10,
itemLockDurationInMilliseconds: 15 * 1000
}, queue, item => {
return new Promise((resolve, reject) => {
console.log("leased", item);
// Resolve false to indicate the item should be retried
// Reject will be retried after the lock expiration
resolve(true);
});
});
queue.on("sizeChanged", (data) => {
//console.log("sizeChanged", data);
});
queue.on("heldSizeChanged", (data) => {
//console.log("heldSizeChanged", data);
});
for (var i = 0; i < 50; i++) {
queue.push("Hello, world!");
queue.push("abc");
queue.push("xyz");
}
2.0.122
2 years ago
2.0.120
3 years ago
2.0.118
3 years ago
2.0.116
3 years ago
2.0.108
3 years ago
2.0.114
3 years ago
2.0.111
3 years ago
2.0.110
3 years ago
2.0.105
3 years ago
2.0.103
3 years ago
2.0.101
3 years ago
2.0.100
3 years ago
2.0.98
3 years ago
2.0.96
3 years ago
2.0.94
3 years ago
2.0.92
3 years ago
2.0.90
3 years ago
2.0.88
3 years ago
2.0.86
3 years ago
2.0.84
3 years ago
2.0.82
3 years ago
2.0.80
3 years ago
2.0.78
3 years ago
2.0.76
3 years ago
2.0.74
3 years ago
2.0.73
3 years ago
2.0.70
3 years ago
2.0.68
3 years ago
2.0.66
3 years ago
2.0.64
3 years ago
2.0.62
3 years ago
2.0.60
3 years ago
2.0.57
3 years ago
2.0.55
3 years ago
2.0.53
3 years ago
2.0.51
3 years ago
2.0.49
3 years ago
2.0.46
3 years ago
2.0.44
3 years ago
2.0.42
3 years ago
2.0.37
3 years ago
2.0.40
3 years ago
2.0.35
3 years ago
2.0.33
3 years ago
2.0.31
3 years ago
2.0.26
3 years ago
2.0.24
3 years ago
2.0.21
3 years ago
2.0.29
3 years ago
2.0.16
3 years ago
2.0.11
3 years ago
2.0.7
3 years ago