26 lines
753 B
TypeScript
26 lines
753 B
TypeScript
import { Service } from 'typedi';
|
|
|
|
import { RedisServicePubSubPublisher } from './redis/redis-service-pub-sub-publisher';
|
|
import { RedisServicePubSubSubscriber } from './redis/redis-service-pub-sub-subscriber';
|
|
|
|
/*
|
|
* This is a convenience service that provides access to all the Redis clients.
|
|
*/
|
|
@Service()
|
|
export class RedisService {
|
|
constructor(
|
|
private redisServicePubSubSubscriber: RedisServicePubSubSubscriber,
|
|
private redisServicePubSubPublisher: RedisServicePubSubPublisher,
|
|
) {}
|
|
|
|
async getPubSubSubscriber() {
|
|
await this.redisServicePubSubSubscriber.init();
|
|
return this.redisServicePubSubSubscriber;
|
|
}
|
|
|
|
async getPubSubPublisher() {
|
|
await this.redisServicePubSubPublisher.init();
|
|
return this.redisServicePubSubPublisher;
|
|
}
|
|
}
|