PubsubManager | redis-messaging-manager

Hierarchy

PubsubManager

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new PubsubManager(options?: Redis.RedisOptions): PubsubManager

- Defined in redis-messaging-manager.ts:8
Parameters
- Optional options: Redis.RedisOptions
Returns PubsubManager

Properties

Private options

options: Redis.RedisOptions

Private redisClient

redisClient: Redis.Redis

Private serverEventsToObservables

serverEventsToObservables: Map<ServerEvent, Observable<any>>

Private topicMaps

topicMaps: Map<string, Observable<any>>

Methods

consume

consume(topic: string): Observable<any>

- Defined in redis-messaging-manager.ts:33
Parameters
- topic: string
Returns Observable<any>

Private createNewEventObservable

createNewEventObservable(event: ServerEvent): Observable<any>

- Defined in redis-messaging-manager.ts:74
Parameters
- event: ServerEvent
Returns Observable<any>

Private createNewTopicObservable

createNewTopicObservable(topic: string): any

- Defined in redis-messaging-manager.ts:50
Parameters
- topic: string
Returns any

Private getDefaultOptions

getDefaultOptions(): Redis.RedisOptions

- Defined in redis-messaging-manager.ts:84
Returns Redis.RedisOptions

getServerEventStream

getServerEventStream(eventName: ServerEvent): Observable<any>

- Defined in redis-messaging-manager.ts:39
Parameters
- eventName: ServerEvent
Returns Observable<any>

publish

publish(topic: string, message: string): Promise<number>

- Defined in redis-messaging-manager.ts:17
Parameters
- topic: string
- message: string
Returns Promise<number>

publishBulk

publishBulk(topic: string, messagesBulk: Array<string>): Promise<any>

- Defined in redis-messaging-manager.ts:21
Parameters
- topic: string
- messagesBulk: Array<string>
Returns Promise<any>

unsubscribe

unsubscribe(topic: string): void

- Defined in redis-messaging-manager.ts:45
Parameters
- topic: string
Returns void

Generated using TypeDoc