export declare class RPCRedisBroker<TEvents extends Record<string, any>, TResponses extends Record<keyof TEvents, any>> extends BaseRedisBroker<TEvents> implements IRPCBroker<TEvents, TResponses>
RPC broker powered by Redis
Constructors
options: RPCRedisBrokerOptions)
constructor(Constructs a new instance of the RPCRedisBroker
class
protectedboolean listening :
Whether this broker is currently polling events
Inherited from: BaseRedisBroker
protectedreadonlyRequired<RPCRedisBrokerOptions> options :
Options this broker is using
protectedreadonlyMap<string, InternalPromise> promises :
Used for Redis queues, see the 3rd argument taken by xadd
Inherited from: BaseRedisBroker
protectedreadonlyRedis streamReadClient :
Internal copy of the Redis client being used to read incoming payloads
Inherited from: BaseRedisBroker
Events this broker has subscribed to
Inherited from: BaseRedisBroker
callEvent extends keyof TEvents
>() : Promise<TResponses[Event]> <
Event extends keyof TEvents
Makes an RPC call
Destroys the broker, closing all connections
Inherited from: BaseRedisBroker
Begins polling for events, firing them to listen
Inherited from: BaseRedisBroker
Subscribes to the given events, grouping them by the given group name
Inherited from: BaseRedisBroker
Unsubscribes from the given events - it's required to pass the same group name as when subscribing for proper cleanup
Inherited from: BaseRedisBroker