Class Service

Service class

Hierarchy

EventEmitter
- Service

Index

Constructors

Methods

command jobs messages on pendingJobs

Constructors

constructor

new Service(model: Model): Service
Create an instance of service
Parameters
- model: Model
  model instance
Returns Service

Methods

command

command(message: CommandMessage): Promise<undefined | CommandResponse>
Execute a command over the producer or consumer
Parameters
- message: CommandMessage
  message to be processed
Returns Promise<undefined | CommandResponse>
- response message

jobs

jobs(): Promise<Result<"command">[]>
Return array of jobs used as fifo registry

Returns Promise<Result<"command">[]>

messages

messages(): Promise<Message[]>
Return array of messages used as fifo registry

Returns Promise<Message[]>

on

on(
event: "command",
listener: (message: CommandMessage, done: CommandResponseHandler) => void,
): this
Event emitted when a command is received
Parameters
- event: "command"
- listener: (message: CommandMessage, done: CommandResponseHandler) => void
Returns this

pendingJobs

pendingJobs(): Promise<Result<"command">[]>
Return array of pendingJobs used as fifo registry

Returns Promise<Result<"command">[]>