(
messageId: string,
consumerGroup: string
)
| 236 | } |
| 237 | |
| 238 | receiveById( |
| 239 | messageId: string, |
| 240 | consumerGroup: string |
| 241 | ): ReceivedMessage | null { |
| 242 | const message = this.messages.get(messageId); |
| 243 | if (!message) return null; |
| 244 | |
| 245 | const { state } = this.findDeliveryState(messageId, consumerGroup); |
| 246 | if (!state) return null; |
| 247 | |
| 248 | return { |
| 249 | messageId: message.messageId, |
| 250 | payload: message.payload, |
| 251 | contentType: message.contentType, |
| 252 | deliveryCount: state.deliveryCount, |
| 253 | createdAt: message.createdAt, |
| 254 | receiptHandle: state.receiptHandle, |
| 255 | }; |
| 256 | } |
| 257 | |
| 258 | receiveMessages( |
| 259 | queueName: string, |
no test coverage detected