Class MoleculerQueryBus

Implementation of the QueryBus for Moleculer.

Hierarchy

MoleculerQueryBus

Implements

QueryBus

Index

Constructors

constructor

Accessors

observer

Methods

Constructors

constructor

new MoleculerQueryBus(emitter: MoleculerEmitterQueryBus, broker: ServiceBroker, services?: Set<Service<ServiceSettingSchema>>): MoleculerQueryBus

- Defined in packages/ceb-messaging-moleculer/src/query.ts:73
Parameters
- emitter: MoleculerEmitterQueryBus
- broker: ServiceBroker
- services: Set<Service<ServiceSettingSchema>> = ...
Returns MoleculerQueryBus

Accessors

observer

get observer(): MoleculerObservableQueryBus

- Defined in packages/ceb-messaging-moleculer/src/query.ts:79
Returns MoleculerObservableQueryBus

Methods

dispose

dispose(): Promise<void>

Implementation of QueryBus.dispose
- Defined in packages/ceb-messaging-moleculer/src/query.ts:149
Returns Promise<void>

execute

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

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

handle

handle<Q, R>(queryType: string, handler: QueryHandler<Q, R>): Removable

Implementation of QueryBus.handle
- Defined in packages/ceb-messaging-moleculer/src/query.ts:111
Type parameters
- Q: Query<any, MessageHeaders, Q> = Query<any, MessageHeaders>
- R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>
Parameters
- queryType: string
- handler: QueryHandler<Q, R>
Returns Removable

Static Private createService

createService<Q, R>(queryType: string, handler: QueryHandler<Q, R>, broker: ServiceBroker, queryBus: QueryBus, emitter: MoleculerEmitterQueryBus): Service<ServiceSettingSchema>

- Defined in packages/ceb-messaging-moleculer/src/query.ts:83
Type parameters
- Q: Query<any, MessageHeaders, Q> = Query<any, MessageHeaders>
- R: Result<any, ResultHeaders, R> = Result<any, ResultHeaders>
Parameters
- queryType: string
- handler: QueryHandler<Q, R>
- broker: ServiceBroker
- queryBus: QueryBus
- emitter: MoleculerEmitterQueryBus
Returns Service<ServiceSettingSchema>

Generated using TypeDoc