| 1 | import Handler from './handler/Handler';
|
| 2 | export declare enum BrokerType {
|
| 3 | RABBITMQ = "RABBITMQ"
|
| 4 | }
|
| 5 | export default class Mercury {
|
| 6 | static handlerRegistry: Map<string, Handler>;
|
| 7 | private messageBus;
|
| 8 | private appName;
|
| 9 | private serviceName;
|
| 10 | private brokerHostName;
|
| 11 | private brokerUserName;
|
| 12 | private brokerPassword;
|
| 13 | private retryDelayTime;
|
| 14 | constructor(brokerType: string, brokerHostName: string, brokerUserName: string, brokerPassword: string, appName: string, serviceName: string, retryDelayTime?: number);
|
| 15 | init(): Promise<boolean>;
|
| 16 | useHandler(handler: Handler): void;
|
| 17 | terminate(): Promise<boolean>;
|
| 18 | }
|