/**
 * 消息队列适配器
 *
 * 支持 RabbitMQ（amqplib）/ Kafka（kafkajs）。
 * 默认只读（消费），发布需显式开启。
 * 工具通过 executorType(mq-*) 路由到 work-client 运行时执行器（见 mcp.service）。
 *
 * 字段读取兼容规范键（mqType / host / port / topics / groupId）与历史别名（mqDriver / mqUrl / mqTopics / mqGroupId / mqWritable）。
 */
import type { DataSourceConfig, DiscoveredTool, ConnectionTestResult, DataSourceAdapter, MCPServerConfig } from '../types.js';
export declare class MessageQueueAdapter implements DataSourceAdapter {
    readonly type: "message-queue";
    readonly label = "\u6D88\u606F\u961F\u5217";
    readonly drivers: string[];
    private delegate;
    testConnection(config: DataSourceConfig): Promise<ConnectionTestResult>;
    discoverTools(config: DataSourceConfig): Promise<DiscoveredTool[]>;
    generateManifest(config: DataSourceConfig, _tools?: DiscoveredTool[]): Record<string, unknown>;
    generateMCPServerConfigs(_config: DataSourceConfig, _tools?: DiscoveredTool[]): MCPServerConfig[];
}
//# sourceMappingURL=mq-adapter.d.ts.map