import { Effect } from "@effect/io/Effect";
import type { OperationOptionsBase, ProcessErrorArgs, ServiceBusMessage, ServiceBusMessageBatch, ServiceBusReceivedMessage, ServiceBusReceiver, ServiceBusSender } from "@azure/service-bus";
import { ServiceBusClient } from "@azure/service-bus";
export declare const LiveServiceBusClient: (url: string) => import("@effect/io/Layer").Layer<never, never, ServiceBusClient>;
export declare const Sender: import("@fp-ts/data/Context").Tag<ServiceBusSender>;
export declare function LiveSender(queueName: string): import("@effect/io/Layer").Layer<ServiceBusClient, never, ServiceBusSender>;
export declare const Receiver: import("@fp-ts/data/Context").Tag<ServiceBusReceiver>;
export declare function LiveReceiver(queueName: string): import("@effect/io/Layer").Layer<ServiceBusClient, never, ServiceBusReceiver>;
export declare function sendMessages(messages: ServiceBusMessage | ServiceBusMessage[] | ServiceBusMessageBatch, options?: OperationOptionsBase): import("@effect/io/Effect").Effect<ServiceBusSender, never, void>;
export declare function subscribe<RMsg, RErr>(hndlr: MessageHandlers<RMsg, RErr>): import("@effect/io/Effect").Effect<import("@effect/io/Scope").Scope | ServiceBusReceiver | RMsg | RErr, never, void>;
export declare function Subscription<RMsg, RErr>(hndlr: MessageHandlers<RMsg, RErr>): import("@effect/io/Layer").Layer<ServiceBusReceiver | Exclude<RMsg, import("@effect/io/Scope").Scope> | Exclude<RErr, import("@effect/io/Scope").Scope>, never, void>;
export interface MessageHandlers<RMsg, RErr> {
    /**
     * Handler that processes messages from service bus.
     *
     * @param message - A message received from Service Bus.
     */
    processMessage(message: ServiceBusReceivedMessage): Effect<RMsg, never, void>;
    /**
     * Handler that processes errors that occur during receiving.
     * @param args - The error and additional context to indicate where
     * the error originated.
     */
    processError(args: ProcessErrorArgs): Effect<RErr, never, void>;
}
//# sourceMappingURL=ServiceBus.d.ts.map