removed dep methods

This commit is contained in:
Boki 2025-06-22 20:55:26 -04:00
parent 190b725149
commit 4d7c7df909
2 changed files with 20 additions and 96 deletions

View file

@ -22,21 +22,24 @@ npm install @stock-bot/queue
### Basic Queue Setup
```typescript
import { QueueManager, providerRegistry } from '@stock-bot/queue';
import { QueueManager, handlerRegistry } from '@stock-bot/queue';
// Initialize queue manager
// Initialize queue manager (typically done via dependency injection)
const queueManager = new QueueManager({
queueName: 'my-service-queue',
workers: 5,
concurrency: 20,
redis: {
host: 'localhost',
port: 6379,
},
});
// Register providers
providerRegistry.register('market-data', {
// Get or create a queue
const queue = queueManager.getQueue('my-service-queue', {
workers: 5,
concurrency: 20,
});
// Register handlers
handlerRegistry.register('market-data', {
'fetch-price': async (payload) => {
// Handle price fetching
return { price: 100, symbol: payload.symbol };
@ -47,8 +50,7 @@ providerRegistry.register('market-data', {
},
});
// Initialize
await queueManager.initialize();
// Queue is ready to use - no initialization needed
```
### Batch Processing
@ -242,8 +244,10 @@ If you're migrating from an existing queue implementation:
await queueService.initialize();
// After
const queueManager = new QueueManager();
await queueManager.initialize();
const queueManager = new QueueManager({
redis: { host: 'localhost', port: 6379 }
});
// No initialization needed
```
3. **Update provider registration**:
@ -252,7 +256,7 @@ If you're migrating from an existing queue implementation:
providerRegistry.register('provider', config);
// After
queueManager.registerProvider('provider', config);
handlerRegistry.register('provider', config);
```
## Examples
@ -281,12 +285,14 @@ See the `/examples` directory for complete implementation examples:
4. **Clean up periodically**:
```typescript
await queueManager.clean(24 * 60 * 60 * 1000); // Clean jobs older than 24h
const queue = queueManager.getQueue('my-queue');
await queue.clean(24 * 60 * 60 * 1000); // Clean jobs older than 24h
```
5. **Monitor queue stats**:
```typescript
const stats = await queueManager.getStats();
const queue = queueManager.getQueue('my-queue');
const stats = await queue.getStats();
console.log('Queue status:', stats);
```