| 1 | import { Counter, Histogram } from 'prom-client';
|
| 2 | import { RabbitmqProducerConfig, RabbitmqClientConfig } from './RabbitmqConfig';
|
| 3 | import { PublishOptions, RabbitmqClient } from './RabbitmqClient';
|
| 4 | export declare class RabbitmqProducer extends RabbitmqClient {
|
| 5 | publishFailures: Counter.Internal;
|
| 6 | publishDurationHistogram: Histogram.Internal;
|
| 7 | protected producerConfig: RabbitmqProducerConfig;
|
| 8 | constructor(clientConfig: RabbitmqClientConfig, name: string, producerConfig: RabbitmqProducerConfig);
|
| 9 | /**
|
| 10 | * publish msg with routing key
|
| 11 | * @param msg
|
| 12 | * @param routingKey
|
| 13 | */
|
| 14 | publish(msg: string, routingKey: string, optionsPublish?: PublishOptions): Promise<boolean>;
|
| 15 | init(): Promise<void>;
|
| 16 | close(): Promise<void>;
|
| 17 | }
|