8720489682

Committed 17 Apr 2024 10:39AM UTC coverage: 92.659% (-0.4%) from 93.068%

Build Type

github

Committed by

Commit Message

Update src/datasources/queues/queues-api.service.ts

Co-authored-by: Aaron Cook <aaron@safe.global>

Run Details

1906 of 2301 branches covered (82.83%)

Branch coverage included in aggregate %.

15 of 53 new or added lines in 6 files covered. (28.3%)

4 existing lines in 1 file now uncovered.

6803 of 7098 relevant lines covered (95.84%)

308.53 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/datasources/queues/queues-api.service.interface.ts

1	import { ConsumeMessage } from 'amqplib';
2
NEW 3	export const IQueuesApiService = Symbol('IQueuesApiService');	×
4
5	export interface IQueuesApiService {
6	/**
7	* Sets an arbitrary {@link fn} function as a callback.
8	* Every time a new message is received into the queue {@link queueName},
9	* this callback function gets executed.
10	*
11	* @param queueName the queue name identifier
12	* @param fn callback function called on every message reception
13	*/
14	subscribe(
15	queueName: string,
16	fn: (msg: ConsumeMessage) => Promise<void>,
17	): Promise<void>;
18	}