Class RabbitMQPublisher

Hierarchy

BasePublisher<IEventLike>
- RabbitMQPublisher

Implements

IPublisher

Constructors

constructor

new RabbitMQPublisher(observableFactory: ObservableFactory, publisherOptions: IRabbitMQPublisherConfig, rabbitMQConnection: RabbitMQConnection): RabbitMQPublisher
Parameters
- observableFactory: ObservableFactory
- publisherOptions: IRabbitMQPublisherConfig
- rabbitMQConnection: RabbitMQConnection
Returns RabbitMQPublisher
Overrides BasePublisher<IEventLike>.constructor
- Defined in moirae/rabbitmq/lib/publishers/rabbitmq.publisher.ts:45

Properties

`Private` _RESPONSE_EXCHANGE

_RESPONSE_EXCHANGE: string

`Private` _RESPONSE_QUEUE

_RESPONSE_QUEUE: string

`Private` _WORK_EXCHANGE

_WORK_EXCHANGE: string

`Private` _activeInbound

_activeInbound: AsyncMap<Message>

`Protected` _distributor

_distributor: Distributor<IEventLike>

`Private` _responseChannel

_responseChannel: Channel

`Private` _responseConsumer

_responseConsumer: string

`Protected` _responseMap

_responseMap: AsyncMap<ResponseWrapper<unknown>>

`Protected` _status

_status: StateTracker<ESState>

`Protected` `Readonly` _uuid

_uuid: string

`Private` _workChannel

_workChannel: Channel

`Private` _workQueueMap

_workQueueMap: Map<string, {
consumerTag?: string;
queueName: string;
}>

Map of Queues by domain

`Protected` publisherOptions

publisherOptions: IRabbitMQPublisherConfig

`Private` `Readonly` rabbitMQConnection

rabbitMQConnection: RabbitMQConnection

role

role: PublisherToken

Accessors

`Protected` _key

get _key(): string
Returns string
Inherited from BasePublisher._key
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:20

Methods

`Private` _generateWorkQueue

_generateWorkQueue(domain: string): string
Parameters
- domain: string
Returns string
- Defined in moirae/rabbitmq/lib/publishers/rabbitmq.publisher.ts:55

acknowledgeEvent

acknowledgeEvent(event: IEventLike): Promise<void>
Parameters
- event: IEventLike
Returns Promise<void>
Inherited from BasePublisher.acknowledgeEvent
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:25

awaitResponse

awaitResponse(responseKey: string): Promise<ResponseWrapper<unknown>>
Parameters
- responseKey: string
Returns Promise<ResponseWrapper<unknown>>
Implementation of IPublisher.awaitResponse

Inherited from BasePublisher.awaitResponse
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:26

beforeApplicationShutdown

beforeApplicationShutdown(): Promise<void>
Returns Promise<void>
Inherited from BasePublisher.beforeApplicationShutdown
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:27

`Protected` getRoleConfig

getRoleConfig<T>(): T
Get specific configuration given the publisher role
Type Parameters
- T extends IPublisherConfig
Returns T
Inherited from BasePublisher.getRoleConfig
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:24

`Protected` handleAcknowledge

handleAcknowledge(event: IEventLike): Promise<void>
Parameters
- event: IEventLike
Returns Promise<void>
Overrides BasePublisher.handleAcknowledge
- Defined in moirae/rabbitmq/lib/publishers/rabbitmq.publisher.ts:60

`Protected` handleBootstrap

handleBootstrap(): Promise<void>
Returns Promise<void>
Overrides BasePublisher.handleBootstrap
- Defined in moirae/rabbitmq/lib/publishers/rabbitmq.publisher.ts:67

`Protected` handlePublish

handlePublish(eventString: string, executionDomain: string): Promise<void>
Parameters
- eventString: string
- executionDomain: string
Returns Promise<void>
Overrides BasePublisher.handlePublish
- Defined in moirae/rabbitmq/lib/publishers/rabbitmq.publisher.ts:150

`Protected` handleResponse

handleResponse(routingKey: string, responseJSON: string): Promise<void>
Parameters
- routingKey: string
- responseJSON: string
Returns Promise<void>
Overrides BasePublisher.handleResponse
- Defined in moirae/rabbitmq/lib/publishers/rabbitmq.publisher.ts:161

`Protected` handleShutdown

handleShutdown(): Promise<void>
Returns Promise<void>
Overrides BasePublisher.handleShutdown
- Defined in moirae/rabbitmq/lib/publishers/rabbitmq.publisher.ts:172

listen

listen(handlerFn: ((event: IEventLike) => void)): string
Listen to the publisher asynchronously without interacting with publisher state
Parameters
- handlerFn: ((event: IEventLike) => void)
  - - (event: IEventLike): void
    - Parameters
      
      event: IEventLike
      
      Returns void
Returns string
Implementation of IPublisher.listen

Inherited from BasePublisher.listen
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:39

onApplicationBootstrap

onApplicationBootstrap(): Promise<void>
Returns Promise<void>
Inherited from BasePublisher.onApplicationBootstrap
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:40

parseEvent

parseEvent(eventString: string): IEventLike
Parameters
- eventString: string
Returns IEventLike
Inherited from BasePublisher.parseEvent
- Defined in moirae/core/dist/lib/mixins/event-processor.mixin.d.ts:3

`Protected` parseResponse

parseResponse(responseString: string): ResponseWrapper<unknown>
Parameters
- responseString: string
Returns ResponseWrapper<unknown>
Inherited from BasePublisher.parseResponse
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:45

plainToInstance

plainToInstance(event: IEventLike): IEventLike
Parameters
- event: IEventLike
Returns IEventLike
Inherited from BasePublisher.plainToInstance
- Defined in moirae/core/dist/lib/mixins/event-processor.mixin.d.ts:4

publish

publish(event: IEventLike): Promise<void>
Publish an event to the wider system
Parameters
- event: IEventLike
Returns Promise<void>
Implementation of IPublisher.publish

Inherited from BasePublisher.publish
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:44

serializeEvent

serializeEvent(event: IEventLike): string
Convert an existing event into JSON
Parameters
- event: IEventLike
Returns string
Inherited from BasePublisher.serializeEvent
- Defined in moirae/core/dist/lib/mixins/event-processor.mixin.d.ts:8

subscribe(handlerFn: ((event: IEventLike) => any)): string
Subscribe to the publisher as a worker.
Parameters
- handlerFn: ((event: IEventLike) => any)
  - - (event: IEventLike): any
    - Parameters
      
      event: IEventLike
      
      Returns any
Returns string
Implementation of IPublisher.subscribe

Inherited from BasePublisher.subscribe
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:49

unsubscribe

unsubscribe(key: string): void
Parameters
- key: string
Returns void
Implementation of IPublisher.unsubscribe

Inherited from BasePublisher.unsubscribe
- Defined in moirae/core/dist/lib/classes/base.publisher.d.ts:50

Class RabbitMQPublisher

Hierarchy

Implements

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Parameters

observableFactory: ObservableFactory

publisherOptions: IRabbitMQPublisherConfig

rabbitMQConnection: RabbitMQConnection

Returns RabbitMQPublisher

Properties

Private _RESPONSE_EXCHANGE

Private _RESPONSE_QUEUE

Private _WORK_EXCHANGE

Private _activeInbound

Protected _distributor

Private _responseChannel

Private _responseConsumer

Protected _responseMap

Protected _status

Protected Readonly _uuid

Private _workChannel

Private _workQueueMap

Protected publisherOptions

Private Readonly rabbitMQConnection

role

Accessors

Protected _key

Returns string

Methods

Private _generateWorkQueue

Parameters

domain: string

Returns string

acknowledgeEvent

Parameters

event: IEventLike

Returns Promise<void>

awaitResponse

Parameters

responseKey: string

Returns Promise<ResponseWrapper<unknown>>

beforeApplicationShutdown

Returns Promise<void>

Protected getRoleConfig

Type Parameters

T extends IPublisherConfig

Returns T

Protected handleAcknowledge

Parameters

event: IEventLike

Returns Promise<void>

Protected handleBootstrap

Returns Promise<void>

Protected handlePublish

Parameters

eventString: string

executionDomain: string

Returns Promise<void>

Protected handleResponse

Parameters

routingKey: string

responseJSON: string

Returns Promise<void>

Protected handleShutdown

Returns Promise<void>

listen

Parameters

handlerFn: ((event: IEventLike) => void)

Parameters

event: IEventLike

Returns void

Returns string

onApplicationBootstrap

Returns Promise<void>

`Private` _RESPONSE_EXCHANGE

`Private` _RESPONSE_QUEUE

`Private` _WORK_EXCHANGE

`Private` _activeInbound

`Protected` _distributor

`Private` _responseChannel

`Private` _responseConsumer

`Protected` _responseMap

`Protected` _status

`Protected` `Readonly` _uuid

`Private` _workChannel

`Private` _workQueueMap

`Protected` publisherOptions

`Private` `Readonly` rabbitMQConnection

`Protected` _key

`Private` _generateWorkQueue

`Protected` getRoleConfig

`Protected` handleAcknowledge

`Protected` handleBootstrap

`Protected` handlePublish

`Protected` handleResponse

`Protected` handleShutdown

`Protected` parseResponse