(
messageId: string,
serviceName: string
)
| 381 | } |
| 382 | |
| 383 | private findDeliveryState( |
| 384 | messageId: string, |
| 385 | serviceName: string |
| 386 | ): { |
| 387 | deliveries: Map<string, DeliveryState> | null; |
| 388 | state: DeliveryState | null; |
| 389 | } { |
| 390 | for (const group of this.consumerGroups) { |
| 391 | if (group.name !== serviceName) continue; |
| 392 | const deliveries = this.deliveryState.get(group.id); |
| 393 | if (!deliveries) continue; |
| 394 | const state = deliveries.get(messageId); |
| 395 | if (state) return { deliveries, state }; |
| 396 | } |
| 397 | return { deliveries: null, state: null }; |
| 398 | } |
| 399 | |
| 400 | private async dispatchToConsumer( |
| 401 | message: StoredMessage, |
no test coverage detected