| 1 | import { ExtendedError } from '../util/ErrorUtil';
|
| 2 | import { PublishOptions } from './RabbitmqClient';
|
| 3 | export interface MessageInfo {
|
| 4 | queueName: string;
|
| 5 | messageContent: string;
|
| 6 | options?: PublishOptions;
|
| 7 | }
|
| 8 | export declare class RabbitmqConsumerHandlerError extends ExtendedError {
|
| 9 | messageInfo: MessageInfo;
|
| 10 | }
|
| 11 | export declare class RabbitmqConsumerHandlerUnrecoverableError extends RabbitmqConsumerHandlerError {
|
| 12 | }
|