2.0.10 • Published 8 days ago
talos-bus v2.0.10
RabbitMQ client using amqplib
Features
- Well-defined API
- Implemented Bus interface for RabbitMQ
- Automatic re-connection
- Message buffering between link failures
- Subscriptions are preserved between re-connections
- Injectable logger, let you use log4js for example
- Easy and intuitive to use
Install
npm install talos-bus
Example
const client = new RabbitMQ(new ClientConfig(
'amqp://guest:guest@localhost:5672'
));
const isConnected: boolean = await client.connect();
const subscription: Subscription = QueueSubscriptionBuilder.newBuilder("logs").isAutoDelete(true).build();
await client.subscribe(subscription);
subscription.on("message", console.log);
const sent: boolean = client.publish(Message.toQueue('logs', Buffer.from('message')));
2.0.10
8 days ago
2.0.5
1 year ago
2.0.7
1 year ago
2.0.6
1 year ago
2.0.9
1 year ago
2.0.8
1 year ago
2.0.3
2 years ago
2.0.2
2 years ago
2.0.4
2 years ago
2.0.1
2 years ago
1.0.13
2 years ago
2.0.0
2 years ago
1.0.9
3 years ago
1.0.11
3 years ago
1.0.10
3 years ago
1.0.12
3 years ago
1.0.8
4 years ago
1.0.7
4 years ago
1.0.6
4 years ago
1.0.5
4 years ago
1.0.4
4 years ago
1.0.3
4 years ago
1.0.2
4 years ago
1.0.1
4 years ago
1.0.0
4 years ago