/** * Warlock Herald - Message Bus * * A powerful, type-safe message bus library for RabbitMQ, Kafka, and more. * * Package: @warlock.js/herald * * Let heralds carry your messages across services! * * Structure: * - contracts/ - Core interfaces * - brokers/ - Broker and registry * - drivers/ - RabbitMQ, Kafka implementations * - types/ - TypeScript type definitions * - utils/ - Connection helpers * * @example * ```typescript * import { connectToBroker, herald } from "@warlock.js/herald"; * * // Connect to RabbitMQ * await connectToBroker({ * driver: "rabbitmq", * host: "localhost", * port: 5672, * }); * * // Publish a message * await herald().channel("user.created").publish({ userId: 1 }); * * // Subscribe to messages * herald() * .channel("user.created") * .subscribe(async (message, ctx) => { * console.log(message.payload); * await ctx.ack(); * }); * ``` */ export * from "./types/index"; export * from "./contracts"; export * from "./communicators"; export * from "./drivers"; export * from "./utils"; export * from "./message-managers"; export * from "./decorators"; //# sourceMappingURL=index.d.ts.map