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
protectedreadonlySet<string> subscribedEvents :
Events this broker has subscribed to
Inherited from: BaseRedisBroker
callT extends keyof TEvents
>() : Promise<TResponses[T]> <
T extends keyof TEvents
Makes an RPC call
destroyPromise<void> () :
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