Awesome
redis-messaging-manager
A super simple, instant pubsub messaging library, using
- ioredis library
- rxjs
- typescript
Background
redis-messaging-manager
is designed to help you implement a pubsub
messaging protocol between your systems services. After installing the
library as a dependency, simply use the PubsubManager
object provided
by the library to setup a connection to a redis broker instance.
The two core functions for messaging are publish
and consume
Creating PubsubManager instance
import {PubsubManager} from 'redis-messaging-manager';
let messenger = new PubsubManager({
host: 'localhost'
});
export default messenger;
Additional parameters can be passed to the instance, such as the broker port, and reconnect strategy (Defaults to reconnecting).
Examples for usage
Examples for using the library are provided here
Out of the box features
consume
method returns an Rx Observable for convenient event processing- Server events can be subscribed to by using
getServerEventStream
method - Auto reconnect to the server is implemented in case of broker failure
- Options to
PubsubManager
instance can be passed for alternative config
Extended documentation
Please check out the extended documentation for more information