Class MoleculerCommandBus

Implementation of the CommandBus for Moleculer.

Hierarchy

MoleculerCommandBus

Implements

CommandBus

Index

Constructors

constructor

Accessors

observer

Methods

Constructors

constructor

new MoleculerCommandBus(eventBus: EventBus, emitter: MoleculerEmitterCommandBus, broker: ServiceBroker, services?: Set<Service<ServiceSettingSchema>>): MoleculerCommandBus

- Defined in packages/ceb-messaging-moleculer/src/command.ts:76
Parameters
- eventBus: EventBus
- emitter: MoleculerEmitterCommandBus
- broker: ServiceBroker
- services: Set<Service<ServiceSettingSchema>> = ...
Returns MoleculerCommandBus

Accessors

observer

get observer(): MoleculerObservableCommandBus

- Defined in packages/ceb-messaging-moleculer/src/command.ts:83
Returns MoleculerObservableCommandBus

Methods

dispose

dispose(): Promise<void>

Implementation of CommandBus.dispose
- Defined in packages/ceb-messaging-moleculer/src/command.ts:199
Returns Promise<void>

execute

execute<R, C>(command: C, options?: Partial<MoleculerExecuteActionOptions>): Promise<R>

Implementation of CommandBus.execute
- Defined in packages/ceb-messaging-moleculer/src/command.ts:173
Type parameters
- R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>
- C: Command<any, MessageHeaders, C> = Command<any, MessageHeaders>
Parameters
- command: C
- Optional options: Partial<MoleculerExecuteActionOptions>
Returns Promise<R>

executeAndForget

executeAndForget<C>(command: C): void

Implementation of CommandBus.executeAndForget
- Defined in packages/ceb-messaging-moleculer/src/command.ts:184
Type parameters
- C: Command<any, MessageHeaders, C> = Command<any, MessageHeaders>
Parameters
- command: C
Returns void

handle

handle<C, R, Es>(commandType: string, handler: CommandHandler<C, R, Es>): Removable

Implementation of CommandBus.handle
- Defined in packages/ceb-messaging-moleculer/src/command.ts:140
Type parameters
- C: Command<any, MessageHeaders, C> = Command<any, MessageHeaders>
- R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>
- Es: Event<any, MessageHeaders>[] = []
Parameters
- commandType: string
- handler: CommandHandler<C, R, Es>
Returns Removable

Static Private createService

createService<C, R, Es>(commandType: string, handler: CommandHandler<C, R, Es>, broker: ServiceBroker, commandBus: CommandBus, eventBus: EventBus, emitter: MoleculerEmitterCommandBus): Service<ServiceSettingSchema>

- Defined in packages/ceb-messaging-moleculer/src/command.ts:97
Type parameters
- C: Command<any, MessageHeaders, C> = Command<any, MessageHeaders>
- R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>
- Es: Event<any, MessageHeaders>[] = []
Parameters
- commandType: string
- handler: CommandHandler<C, R, Es>
- broker: ServiceBroker
- commandBus: CommandBus
- eventBus: EventBus
- emitter: MoleculerEmitterCommandBus
Returns Service<ServiceSettingSchema>

Static Private publishEvents

publishEvents<R, Es>(eventBus: EventBus, output: CommandHandlerOutputSync<R, Es>): void | CommandResult<R>

- Defined in packages/ceb-messaging-moleculer/src/command.ts:87
Type parameters
- R: Result<any, ResultHeaders, R>
- Es: Event<any, MessageHeaders>[] = []
Parameters
- eventBus: EventBus
- output: CommandHandlerOutputSync<R, Es>
Returns void | CommandResult<R>

Generated using TypeDoc