Properties
Private Optional _options
_options: any
Private client
client: any
Private closeHandler
closeHandler: Function
Private consumer
consumer: any
Private handlers
handlers: object
Private producer
producer: any
Methods
close
- close(err: Error): Promise<void>
-
Parameters
Returns Promise<void>
Private createTopics
- createTopics(): Promise<any>
handle
- handle(route: string, group: string, callback: Function): void
-
Parameters
-
route: string
-
group: string
-
callback: Function
Returns void
listen
- listen(callback: Function): Promise<void>
-
Parameters
-
Optional callback: Function
Returns Promise<void>
Private normalizeTopic
- normalizeTopic(topic: string): string
-
Parameters
Returns string
onClose
- onClose(callback: function): void
publish
- publish(topic: string, message: any): any
-
Parameters
-
topic: string
-
message: any
Returns any
request
- request(route: string, payload: any, callback: Function, timeout?: number): void
-
Parameters
-
route: string
-
payload: any
-
callback: Function
-
Default value timeout: number = 200
Returns void
subscribe
- subscribe(topic: string, group: string, handle: Function): void
-
Parameters
-
topic: string
-
group: string
-
handle: Function
Returns void