2.0.122 • Published 2 years ago

@tix-factory/queueing v2.0.122

Weekly downloads
13
License
MIT
Repository
github
Last release
2 years ago

@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