MessageBroker | celery-ts

MessageBroker encapsulates transactions with message brokering middleware.

Hierarchy

MessageBroker

Implemented by

Index

Methods

Methods

disconnect

disconnect(): Promise<void>

- Defined in message_broker.ts:43
If possible, quickly disconnects from the broker. Call only once.

Returns Promise<void>

A Promise that resolves when the broker is disconnected.

end

end(): Promise<void>

- Defined in message_broker.ts:50
Gently disconnects from the broker. Should only be called once.

Returns Promise<void>

A Promise that resolves when the broker is disconnected.

publish

publish(message: TaskMessage): Promise<string>

- Defined in message_broker.ts:60
Publishes a message onto the broker.

Parameters
- message: TaskMessage
  
  The message to be published. Used to infer transport options.
Returns Promise<string>

A Promise that resolves to the response of the broker after the operation is completed.

Generated using TypeDoc