I set theses options in the message consumer:
app.connectMicroservice<MicroserviceOptions>({
transport: Transport.TCP,
options: {
host: '127.0.0.1',
port: 4000,
retryAttempts: 3,
retryDelay: 3000,
},
})
I'm throwing an error when the logic fail in the controller
@EventPattern('example_msm')
async exapleMSM(message: exampleMSMDto): Promise<ExampleMSMResultDto> {
try{
...
} catch (error) {
throw new RpcException(error.message)
}
}
however it doesn't retry when it fails